Options
All
  • Public
  • Public/Protected
  • All
Menu

External module "common/parallel/stream/parallel-stream-impl"

Index

Classes

Type aliases

Type aliases

IExecutorCallback

IExecutorCallback: function

Callback that is invoked for a new ParallelStream

param

callback to invoke to trigger the next sub result

param

callback to invoke to resolve the stream

param

callback to invoke to reject the stream

Type declaration

INextCallback

INextCallback: function

Function that resolves the next sub result for a parallel stream

param

the sub result

param

the job relative index of the task that has computed the sub result

param

the number of values each task has to process at most

param

type of the sub result

Type declaration

    • (subResult: TSubResult, taskIndex: number, valuesPerTask: number): any

    • Parameters

      • subResult: TSubResult
      • taskIndex: number
      • valuesPerTask: number

      Returns any

IRejectCallback

IRejectCallback: function

Function to reject a parallel stream

param

the rejection reason

Type declaration

    • (reason: any): any

    • Parameters

      • reason: any

      Returns any

IResolveCallback

IResolveCallback: function

Function that resolves the end result of a parallel stream

param

the end result of the stream

param

type of the end result

Type declaration

    • (result: TEndResult): any

    • Parameters

      • result: TEndResult

      Returns any

NextHandler

NextHandler: function

Type declaration

    • (subResult: TSubResult, worker: number, valuesPerWorker: number): void

    • Parameters

      • subResult: TSubResult
      • worker: number
      • valuesPerWorker: number

      Returns void

Generated using TypeDoc