Class RxjsStreamInput<T>

A StreamPipelineInput implemented using Rxjs' subscribers.

author: Thomas Minier

Type parameters

T

Hierarchy

RxjsStreamInput

Implements

StreamPipelineInput<T>

Index

Constructors

constructor

Properties

_subscriber

Methods

Constructors

constructor

new RxjsStreamInput(subscriber: Subscriber<T>): RxjsStreamInput

- Defined in src/engine/pipeline/rxjs-pipeline.ts:54
Parameters
- subscriber: Subscriber<T>
Returns RxjsStreamInput

Properties

Private _subscriber

_subscriber: Subscriber<T>

Methods

complete

complete(): void

Implementation of StreamPipelineInput.complete
- Defined in src/engine/pipeline/rxjs-pipeline.ts:64
Returns void

error

error(err: any): void

Implementation of StreamPipelineInput.error
- Defined in src/engine/pipeline/rxjs-pipeline.ts:68
Parameters
- err: any
Returns void

next

next(value: T): void

Implementation of StreamPipelineInput.next
- Defined in src/engine/pipeline/rxjs-pipeline.ts:60
Parameters
- value: T
Returns void

Generated using TypeDoc