This module extends the capabilities offered by Rx.Observable.fromEvent(), by allowing multiple kinds of events to be handled in one of the three ways a subscription allows.
Example: suppose that message is of type http.IncomingMessage; you can use several kinds of events from it and they will be treated in one of the three ways corresponding to the subscription mechanism:
- ['data']: put here the normal events, and their outputs will be given to
next(); - ['error']: put here the error events, and their outputs will be given to
error(); - ['close', 'end']: put here the events corresponding to
complete().
The events arrays must be given in that order: next, error, complete.
So you can write:
makeRxObservableFromEventEmitter<Buffer>(message, ['data'], ['error'], ['close', 'end'])
In some cases, the normal output is an Array, such as Buffer[]. In these cases, use this function:
makeRxObservableFromEventEmitterArray<Buffer>(emitter, ['data'], ['error'], ['close', 'end'])