the results produced by a single task that needs to be joined to the end result
the joined result of all tasks.
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.
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
Parallel processing stream that allows access to the sub results or end result of a IParallelJob
The end result can be retrieved by using the then function. The then function is called with the merged result of all tasks. At the other hand, subscribe can be used to register an onNext handler that is called with the result of every spawned task. This allows to stream to the task results and using intermediate results until all tasks have completed.
Catch can be used to register to task failures. Without a catch handler, task failures are silently ignored. The stream implements a fast fail interface. If any task fail, all other tasks are canceled.