ParallelChainImpl | Parallel ES

Implementation of a IParallelChain

The implementation uses an internal state (IParallelChainState) to distinguishes between a not yet scheduled job (PendingParallelChainState), a job that has been scheduled but potentially not yet completed (ScheduledParallelChainState) and a job that is waiting for another one to complete, but has not yet been scheduled (DependentParallelChainState).

Type parameters

TIn

type of the elements created by the generator
TEnv: IParallelEnvironment

type of the job environment
TOut

type of the elements in the resulting array

Hierarchy

ParallelChainImpl

Implements

IParallelChain<TIn, TEnv, TOut>

Index

Constructors

constructor

Properties

state

Methods

Constructors

constructor

new ParallelChainImpl(state: IParallelChainState<TOut>): ParallelChainImpl

- Defined in common/parallel/chain/parallel-chain-impl.ts:23
Creates a new parallel chain with the given state

Parameters
- state: IParallelChainState<TOut>
  
  the state of the chain
Returns ParallelChainImpl

Properties

state

state: IParallelChainState<TOut>

Methods

Private _chain

_chain<TResult>(iterator: FunctionCall, iteratee: FunctionCall): ParallelChainImpl<TIn, TEnv, TResult>

- Defined in common/parallel/chain/parallel-chain-impl.ts:102
Type parameters
- TResult
Parameters
- iterator: FunctionCall
- iteratee: FunctionCall
Returns ParallelChainImpl<TIn, TEnv, TResult>

catch

catch<TResult>(onrejected: function): Promise<TResult | TOut[]>
catch(onrejected: function): Promise<TOut[]>

- Defined in common/parallel/chain/parallel-chain-impl.ts:90
Type parameters
- TResult
Parameters
- onrejected: function
  - - (reason: any): TResult | PromiseLike<TResult>
    - Parameters
      - reason: any
      Returns TResult | PromiseLike<TResult>
Returns Promise<TResult | TOut[]>
- Defined in common/parallel/chain/parallel-chain-impl.ts:91
Parameters
- onrejected: function
  - - (reason: any): Array<TOut> | PromiseLike<Array<TOut>>
    - Parameters
      - reason: any
      Returns Array<TOut> | PromiseLike<Array<TOut>>
Returns Promise<TOut[]>

filter

filter(predicate: function | IFunctionId): IParallelChain<TIn, TEnv, TOut>

- Defined in common/parallel/chain/parallel-chain-impl.ts:70
Parameters
- predicate: function | IFunctionId
Returns IParallelChain<TIn, TEnv, TOut>

inEnvironment

inEnvironment<TEnvNew>(newEnv: Function | IParallelEnvironment | IFunctionId, ...params: any[]): IParallelChain<TIn, TEnv & TEnvNew, TOut>

- Defined in common/parallel/chain/parallel-chain-impl.ts:34
Type parameters
- TEnvNew: IParallelEnvironment
Parameters
- newEnv: Function | IParallelEnvironment | IFunctionId
- Rest ...params: any[]
Returns IParallelChain<TIn, TEnv & TEnvNew, TOut>

map

map<TResult>(mapper: function | IFunctionId): IParallelChain<TIn, TEnv, TResult>

- Defined in common/parallel/chain/parallel-chain-impl.ts:47
Type parameters
- TResult
Parameters
- mapper: function | IFunctionId
Returns IParallelChain<TIn, TEnv, TResult>

reduce

reduce<TResult>(defaultValue: TResult, accumulator: function | IFunctionId, combiner?: undefined | function): IParallelStream<TResult[], TResult>

- Defined in common/parallel/chain/parallel-chain-impl.ts:51
Type parameters
- TResult
Parameters
- defaultValue: TResult
- accumulator: function | IFunctionId
- Optional combiner: undefined | function
Returns IParallelStream<TResult[], TResult>

Private resolveChain

resolveChain(): IParallelStream<TOut[], TOut[]>

- Defined in common/parallel/chain/parallel-chain-impl.ts:96
Returns IParallelStream<TOut[], TOut[]>

subscribe(onNext: function, onError?: undefined | function, onComplete?: undefined | function): IParallelStream<TOut[], TOut[]>

- Defined in common/parallel/chain/parallel-chain-impl.ts:77
Parameters
- onNext: function
  - - (subResult: TOut[], taskIndex: number, valuesPerWorker: number): void
    - Parameters
      - subResult: TOut[]
      - taskIndex: number
      - valuesPerWorker: number
      Returns void
- Optional onError: undefined | function
- Optional onComplete: undefined | function
Returns IParallelStream<TOut[], TOut[]>

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>

- Defined in common/parallel/chain/parallel-chain-impl.ts:81
Type parameters
- TResult1
- TResult2
Parameters
- onfulfilled: function
  - - (value: TOut[]): TResult1 | PromiseLike<TResult1>
    - Parameters
      - value: TOut[]
      Returns TResult1 | PromiseLike<TResult1>
- onrejected: function
  - - (reason: any): TResult2 | PromiseLike<TResult2>
    - Parameters
      - reason: any
      Returns TResult2 | PromiseLike<TResult2>
Returns Promise<TResult2 | TResult1>
- Defined in common/parallel/chain/parallel-chain-impl.ts:82
Type parameters
- TResult
Parameters
- onfulfilled: function
  - - (value: TOut[]): TResult | PromiseLike<TResult>
    - Parameters
      - value: TOut[]
      Returns TResult | PromiseLike<TResult>
- onrejected: function
  - - (reason: any): TResult | PromiseLike<TResult>
    - Parameters
      - reason: any
      Returns TResult | PromiseLike<TResult>
Returns Promise<TResult>
- Defined in common/parallel/chain/parallel-chain-impl.ts:83
Type parameters
- TResult
Parameters
- onfulfilled: function
  - - (value: TOut[]): TResult | PromiseLike<TResult>
    - Parameters
      - value: TOut[]
      Returns TResult | PromiseLike<TResult>
Returns Promise<TResult>
- Defined in common/parallel/chain/parallel-chain-impl.ts:84
Type parameters
- TResult
Parameters
- Optional onfulfilled: undefined | function
- Optional onrejected: undefined | function
Returns Promise<TResult>
- Defined in common/parallel/chain/parallel-chain-impl.ts:85
Type parameters
- TResult
Parameters
- Optional onfulfilled: undefined | function
- Optional onrejected: undefined | function
Returns Promise<TResult>

Type parameters

TIn

TEnv: IParallelEnvironment

TOut

Hierarchy

Implements

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

state: IParallelChainState<TOut>

Returns ParallelChainImpl

Properties

state

Methods

Private _chain

Type parameters

TResult

Parameters

iterator: FunctionCall

iteratee: FunctionCall

Returns ParallelChainImpl<TIn, TEnv, TResult>

catch

Type parameters

TResult

Parameters

onrejected: function

Parameters

reason: any

Returns TResult | PromiseLike<TResult>

Returns Promise<TResult | TOut[]>

Parameters

onrejected: function

Parameters

reason: any

Returns Array<TOut> | PromiseLike<Array<TOut>>

Returns Promise<TOut[]>

filter

Parameters

predicate: function | IFunctionId

Returns IParallelChain<TIn, TEnv, TOut>

inEnvironment

Type parameters

TEnvNew: IParallelEnvironment

Parameters

newEnv: Function | IParallelEnvironment | IFunctionId

Rest ...params: any[]

Returns IParallelChain<TIn, TEnv & TEnvNew, TOut>

map

Type parameters

TResult

Parameters

mapper: function | IFunctionId

Returns IParallelChain<TIn, TEnv, TResult>

reduce

Type parameters

TResult

Parameters

defaultValue: TResult

accumulator: function | IFunctionId

Optional combiner: undefined | function

Returns IParallelStream<TResult[], TResult>

Private resolveChain

Returns IParallelStream<TOut[], TOut[]>

subscribe

Parameters

onNext: function

Parameters

subResult: TOut[]

taskIndex: number

valuesPerWorker: number

Returns void

Optional onError: undefined | function

Optional onComplete: undefined | function

Returns IParallelStream<TOut[], TOut[]>

then

Type parameters