Redux Observable WebSocket

webSocketFailureEpics.ts

const connectEpic = (action$, state$: StateObservable<IState>) =>
  action$
    .ofType(WebsocketActionTypes.CONNECT)
    .switchMap((action: IConnectWebsocketAction) =>
      connectSocket(state$.value.config.webSocketURL)
        .map(data => receiveMessageFromWebSocket(data))
        .catch(e => of(disconnect(true))) // <-- Handle 1st case by using catch operator
    );

const connectedEpic = action$ =>
  action$.ofType(WebsocketActionTypes.CONNECT).switchMap(() =>
    onOpenSubject.map(() => {
      onCloseSubject.map(() => disconnect(true)); // <-- Handle 2nd case by listening to onCloseSubject
      return connected();
    })
  );