This is an internal implementation detail, do not use.
This is an internal implementation detail, do not use.
This is an internal implementation detail, do not use.
forEach
a promise that either resolves on observable completion or rejects with the handled error
a handler for each value emitted by the observable
Optional
promiseCtor: PromiseConstructorLikea constructor function used to instantiate the Promise
Creates a new Observable, with this Observable as the source, and the passed operator defined as the new observable's operator.
lift
a new observable with the Operator applied
the operator defining the operation to take on the observable
Rest
...operations: OperatorFunction<any, any>[]Optional
observer: PartialObserver<ChannelMessage>Use an observer instead of a complete callback
Use an observer instead of an error callback
Optional
complete: (() => void)Use an observer instead of a complete callback
Optional
next: ((value: ChannelMessage) => void)Optional
error: ((error: any) => void)Optional
complete: (() => void)Generated using TypeDoc
Internal implementation detail, do not use directly.