Function pipeTo

lib/command.ts:343–345

* Pipes all events emitted by `stream` into `subject`.

(stream: Rx.Observable<T>, subject: Rx.Subject<T>)

 * Pipes all events emitted by `stream` into `subject`.
 */
function pipeTo<T>(stream: Rx.Observable<T>, subject: Rx.Subject<T>) {
    return stream.subscribe((event) => subject.next(event));
}