docs: public synchronized void resumeReceives() {
          receivesSuspended = false;if(Thread.currentThread() == channel.getIoThread()) {
              doResume();
          } else {
              channel.getIoThread().execute(new Runnable() {
                  @Override
                  public void run() {
                      doResume();
                  }
              });
          }
      }