rxjs-websocket-4.js

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

const wsSubjec2$ = webSocket({
  url: 'wss://www.gasnow.org/ws/gasprice',
});

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