docs: public synchronized void suspendReceives() {
          receivesSuspended = true;
          if (receiver == null) {
              if(Thread.currentThread() == channel.getIoThread()) {
                  channel.getSourceChannel().suspendReads();
              } else {
                  channel.getIoThread().execute(new Runnable() {
                      @Override
                      public void run() {
                          channel.getSourceChannel().suspendReads();
                      }
                  });
              }
          }
      }