import { Subject, Observable } from 'rxjs'; export const pushToSubject = (subject: Subject) => ( stream: Observable ): Observable => new Observable(subscriber => { subscriber.add( stream.subscribe({ next: data => subject.next(data), error: err => subscriber.error(err), complete: () => subscriber.complete(), }) ); });