the input values created by a generator function
the type of the environment
the type of the resulting elements
Attaches a callback for only the rejection of the Promise.
The callback to execute when the Promise is rejected.
A Promise for the completion of the callback.
Attaches a callback for only the rejection of the Promise.
The callback to execute when the Promise is rejected.
A Promise for the completion of the callback.
Filters the input elements using the given predicate
the predicate to use to filter the elements
Defines the environment that is provided to all iteratee or generator functions. The environment cannot contain function values. The values of the provided environment is merged with the values of any prior defined environments. If an environment provider is defined, then the values returned by the environment provider have a higher precedence.
the environment that is provided to the iteratee function
Defines a function that should be used to build the environment for each task. The function is executed first on the scheduled task.
the type of the environment
the function providing the environment
the chain
the type of the single parameter
single parameter that is passed to the provider
type of the first parameter
type of the second parameter
first parameter that is passed to the provider function
second parameter that is passed to the provider function
type of the third parameter
third parameter that is passed to the provider funciton
type of the fourth parameter
fourth parameter that is passed to the provider function
further paramters that are passed to the provider function
Maps all input values to an output value using the given mapper. The mapper is applied for each input element
the type of the resulting elements
the mapper to apply for each element
Reduces the elements to a single value using the given accumulator. The accumulator is invoked with the - up to now - accumulated value and the current element and returns the sum of the accumulated value and the current value.
default value to use to initialize the accumulator
the accumulator function
parallel stream that allows to query the end result
Reduces the elements to a single value using the givne accumulator. The accumulator is invoked with the - up to now - accumulated value and the current element and returns the sum of the accumulated value and the current value.
type of the end result
default value to use to initialize the accumulator
the accumulator function
parallel stream that allows to query the end result
Registers the given next, error and complete handler.
is called with the sub result produced by a completed task. The sub result of this task, the relative task number and the values processed by each worker (max) is passed to the onNext handler.
is invoked whenever any task has failed.
is invoked with the joined result when all tasks have completed
Attaches callbacks for the resolution and/or rejection of the Promise.
The callback to execute when the Promise is resolved.
The callback to execute when the Promise is rejected.
A Promise for the completion of which ever callback is executed.
Attaches callbacks for the resolution and/or rejection of the Promise.
The callback to execute when the Promise is resolved.
The callback to execute when the Promise is rejected.
A Promise for the completion of which ever callback is executed.
Attaches callbacks for the resolution and/or rejection of the Promise.
The callback to execute when the Promise is resolved.
A Promise for the completion of which ever callback is executed.
Generated using TypeDoc
The parallel chain allows to chain multiple operations before they are executed on a worker. The parallel job is scheduled onto the thread pool as soon any terminating function like IParallelChain.then, IParallelChain.catch, IParallelChain.subscribe or IParallelChain.reduce is called.