Angular RXjs Websocket

import { webSocket, WebSocketSubject } from 'rxjs/webSocket';

const wsSubject: WebSocketSubject<any> = webSocket({
  url: 'wss://your-websocket-server.com',
  heartbeat: {
    incoming: 45000,
    outgoing: 30000
  },
  reconnect: true,
  connectionTimeout: 5000
});

wsSubject.subscribe(
  msg => console.log('message received: ' + msg),
  err => console.log(err),
  () => console.warn('complete')
);

import { fromEvent, interval } from 'rxjs';
import { map, mergeMap, takeUntil } from 'rxjs/operators';

const click$ = fromEvent(document, 'click');
const timer$ = interval(1000);

click$.pipe(
  mergeMap(() => timer$.pipe(takeUntil(click$))),
  map(count => `Clicked ${count} times`)
).subscribe(console.log);