microsoft signalr stream converted to rxjs stream for greater flexibility

getSignalRStreamRx.ts

import {HubConnection} from '@microsoft/signalr';

//payload can be a one off payload or a Subject
export const getSignalRStreamRx = (hubConnection: HubConnection, operation: string, payload: any) => new Observable(observer => {
    const subscription = hubConnection.stream(observer, operation, payload);

    return {
        unsubscribe: () => {
            subscription.unsubscribe();
        }
    }
});