Redux Observable WebSocket

webSocketConnectedEpics.ts

// Detect successfull connection by listening to onOpenSubject
const connectedEpic = action$ =>
  action$.ofType(WebsocketActionTypes.CONNECT).switchMap(() =>
    onOpenSubject.map(() => {
      return connected();
    })
  );