Options
All
  • Public
  • Public/Protected
  • All
Menu

Class DependentParallelChainState<TPrevious, TElement>

The state of a parallel chain if additional operations should be performed on an already scheduled parallel chain.

The state needs to wait for the previous parallel job to complete and then take that result to continue the additional computations.

Type parameters

  • TPrevious

    Type of the array elements of the dependent stream

  • TElement

    Type of the array elements of the resulting array

Hierarchy

  • DependentParallelChainState

Implements

Index

Constructors

constructor

Properties

Private environment

the environment used by the job

Private operations

operations: IParallelOperation[]

the operations to performed when the previous stream has completed

Private options

the options used by this parallel job

Private previousStream

previousStream: IParallelStream<TPrevious[], TPrevious[]>

the stream upon which the new stream depends on

Methods

addEnvironment

chainOperation

resolve

Generated using TypeDoc