rxjs-websocket-5.js

import { tap, retryWhen } from 'rxjs/operators';
import { webSocket } from 'rxjs/webSocket';
import { timer } from 'rxjs';

const wsSubjectConfig = {
  url: 'wss://www.gasnow.org/ws/gasprice',
  // added this to the config object
  closeObserver: {
    // this is triggered when connection is closed
    next(event) {
      if (!event.wasClean) {
        connect(); //
      }
    },
  },
}

const wsSubject$ = webSocket(wsSubjectConfig);

function connect() {
  wsSubject$
    .pipe(
      tap((data) => console.log(data)),
      retryWhen((errors) => errors.pipe(delayWhen((val) => timer(val * 1000))))
    )
    .subscribe();
}

connect();