WebSocket Redux Observable

webSocketConnectEpics.ts

let webSocketSubject: WebSocketSubject<{}>;
let onOpenSubject = new Subject();
let onCloseSubject = new Subject();

// Create the websocket subject
const createSocket = websocketUrl => {
  onOpenSubject = new Subject();
  onCloseSubject = new Subject();
  webSocketSubject = webSocket({
    url: websocketUrl,
    openObserver: onOpenSubject,
    closeObserver: onCloseSubject
  });
  return webSocketSubject;
};

// Connect to web socket
const connectEpic = (action$, state$: StateObservable<IState>) =>
  action$
    .ofType(WebsocketActionTypes.CONNECT)
    .switchMap((action: IConnectWebsocketAction) =>
      createSocket(action.payload.websocketUrl)
    );