Interface StreamPipelineInput<T>

An input of a PipelineStage which produces items in stream/async way. Usefull for connecting a Node.JS stream into a pipeline of iterators.

author: Thomas Minier

Type parameters

T

Hierarchy

StreamPipelineInput

Implemented by

Index

Methods

Methods

complete

complete(): void

- Defined in src/engine/pipeline/pipeline-engine.ts:54
Close the pipeline input

Returns void

error

error(err: any): void

- Defined in src/engine/pipeline/pipeline-engine.ts:60
Report an error that occurs during execution

Parameters
- err: any
  
  The error to report
Returns void

next

next(value: T): void

- Defined in src/engine/pipeline/pipeline-engine.ts:49
Produces a new value and inject it into the pipeline

Parameters
- value: T
  
  New value produced
Returns void

Generated using TypeDoc