Jak uniknąć wielokrotnych połączeń z RSocket/WebSocket

class RSocketHandler {
  constructor({
    url = "http://localhost:8080/rsocket",
    debug = false,
    store = null
  } = {}) {
    this.url = url;
    this.debug = debug;
    this.store = store;    
    this.socket = null;
  }

  isConnected() {
    if (this.socket) return this.socket.availability();
    return 0;
  }

  connect(completeCallback) {   

    const client = new RSocketClient({
      // send/receive JSON objects instead of strings/buffers
	  //....      
    });
    client.connect().subscribe({
      onComplete: socket => {
        if (this.isConnected()) {
          socket.close();
        } else {
          this.socket = socket;
        }        
        if (completeCallback) completeCallback(socket);
      },
      onError: error => {
        console.error(error);
      },
      onSubscribe: cancel => {
        console.log(cancel);
      }
    });
  }

  requestResponse(payload, completeCallback, errorCallback, subscribeCallback) {    
    if (!this.isConnected()) {
      console.log("not connected...");
      this.connect(socket => {
        return this.requestResponse(
          payload,
          completeCallback,
          errorCallback,
          subscribeCallback
        );
      });
    } else {
      this.socket
        .requestResponse({
          data: payload.data,
          metadata: String.fromCharCode(payload.route.length) + payload.route
        })
        .subscribe({
          onComplete: data => {
            console.log(data.data);
            if (completeCallback) completeCallback(data);
          },
          onError: error => {
            console.error(error);
            if (errorCallback) errorCallback(error);
          },
          onSubscribe: cancel => {
            if (errorCallback) subscribeCallback(cancel);
          }
        });
    }
  }
}