const wsService = new WebSocketClientService(WebSocketEnvironment.Node);
const handleMessage = (data) => {
  console.debug("data: " + data);
};
const subMessages = <Subject<MessageEvent>>wsService
  .create(URL)
  .pipe(
    map((response: MessageEvent): any => {
      // We have to parse because message data is always text
      const data = JSON.parse(response.data);
      handleMessage(data);
      return data;
    }));