createWebSocketConnection.js

const WebSocket = require('ws')
const { webSocket } = require('rxjs/webSocket')

const createWebSocketConnection = ({
  protocol,
  url,
}) => (
  webSocket({
    protocol,
    url,
    WebSocketCtor: WebSocket,
  })
)

module.exports = createWebSocketConnection

listenToWebSocketConnection.js

const { timer } = require('rxjs')

const createWebSocketConnection = require('./createWebSocketConnection')

const listenToWebSocketConnection = ({
  callback,
  connectionInfo,
  reconnectTimeout = 5000,
}) => (
  createWebSocketConnection(
    connectionInfo
  )
  .subscribe({
    error: (
      timer(
        reconnectTimeout,
      )
      .subscribe(() => (
        listenToWebSocketConnection(
          callback
        )
      ))
    ),
    next: callback,
  })
)

module.exports = listenToWebSocketConnection