docs: public void backpressureBarrier() throws InterruptedException, IOException {
          ClientImpl currentClient = this.getClient();
          if (currentClient == null) {
              throw new IOException("Client is unavailable for backpressureBarrier().");
          }
          currentClient.backpressureBarrier();
      }