type of the sub results
type of the end result
The accumulated end result for all yet completed tasks. Is undefined if the stream is complete.
Indicator if any task has failed. If this is the case, then registered next handlers are no longer called for outstanding results.
Function used to join the sub results to the end result
The index of the next expected sub result that should be joined with the end result
Number of still pending tasks
Rejects the _promise with the given reason
Resolves the _promise with the given end result
Not yet joined sub results
The tasks executed by this stream. Already completed tasks are replaced with undefined to free the reference to the task (gc can collect the task)
Joins the currently outstanding sub results. The sub results is needed to ensure that the results are joined in task order. This method iterates until it either reaches the end of the sub results or a sub result for a task is missing (undefined, not yet computed). Has a better memory footprint compared to if all subresults are kept.
Generated using TypeDoc
Stream that has been scheduled on the thread pool and waits for completion of its tasks.