Class ResolvedParallelStream<TSub, TOut>
Properties
Private promise
promise: Promise<TOut>
Methods
catch
- catch<TResult>(onrejected: function): Promise<TResult | TOut>
- catch(onrejected: function): Promise<TOut>
-
Type parameters
Parameters
-
onrejected: function
-
- (reason: any): TResult | PromiseLike<TResult>
-
Parameters
Returns TResult
|
PromiseLike<TResult>
Returns Promise<TResult | TOut>
-
Parameters
-
onrejected: function
-
- (reason: any): TOut | PromiseLike<TOut>
-
Parameters
Returns TOut
|
PromiseLike<TOut>
Returns Promise<TOut>
subscribe
- subscribe(onNext: function, onError?: undefined | function, onComplete?: undefined | function): IParallelStream<TSub, TOut>
-
Parameters
-
onNext: function
-
- (subResult: TSub, taskIndex: number, valuesPerWorker: number): void
-
Parameters
-
subResult: TSub
-
taskIndex: number
-
valuesPerWorker: number
Returns void
-
Optional onError: undefined | function
-
Optional onComplete: undefined | function
then
- then<TResult1, TResult2>(onfulfilled: function, onrejected: function): Promise<TResult2 | TResult1>
- then<TResult>(onfulfilled: function, onrejected: function): Promise<TResult>
- then<TResult>(onfulfilled: function): Promise<TResult>
- then<TResult>(onfulfilled?: undefined | function, onrejected?: undefined | function): Promise<TResult>
- then<TResult>(onfulfilled?: undefined | function, onrejected?: undefined | function): Promise<TResult>
-
Type parameters
Parameters
-
onfulfilled: function
-
- (value: TOut): TResult1 | PromiseLike<TResult1>
-
Parameters
Returns TResult1
|
PromiseLike<TResult1>
-
onrejected: function
-
- (reason: any): TResult2 | PromiseLike<TResult2>
-
Parameters
Returns TResult2
|
PromiseLike<TResult2>
Returns Promise<TResult2 | TResult1>
-
Type parameters
Parameters
-
onfulfilled: function
-
- (value: TOut): TResult | PromiseLike<TResult>
-
Parameters
Returns TResult
|
PromiseLike<TResult>
-
onrejected: function
-
- (reason: any): TResult | PromiseLike<TResult>
-
Parameters
Returns TResult
|
PromiseLike<TResult>
Returns Promise<TResult>
-
Type parameters
Parameters
-
onfulfilled: function
-
- (value: TOut): TResult | PromiseLike<TResult>
-
Parameters
Returns TResult
|
PromiseLike<TResult>
Returns Promise<TResult>
-
Type parameters
Parameters
-
Optional onfulfilled: undefined | function
-
Optional onrejected: undefined | function
Returns Promise<TResult>
-
Type parameters
Parameters
-
Optional onfulfilled: undefined | function
-
Optional onrejected: undefined | function
Returns Promise<TResult>
Parallel stream for a static, already resolved result.
This stream has no sub results as the end result is already known. It can also never fail.