SignalR Observable

signal-r-observable.js

  public foo(): Observable<any> {
    if (this.connection) {
      const subject: Subject<any> = new Subject<any>();

      this.connection.on('', (bar): void => {
        subject.next(bar);
      });

      this.connection.onclose((err?: Error): void => {
        if (err) {
          subject.error(err);
        } else {
          subject.complete();
        }
      });

      this.connection.start();

      return subject;
    }
    return of(null);
  }