test.java

  /**
   * <p>Whenever a the {@link Reader} Interfaces {@link Reader#onRead(Client)} is called the
   * {@link #getRead()} should be called from the client.</p>
   * 
   * @return a {@link ReuseableMergedByteBuffers} of the current read data for this client.
   */
  public ReuseableMergedByteBuffers getRead() {
    final SettableListenableFuture<ReuseableMergedByteBuffers> slf = new SettableListenableFuture<>();
    this.clientExecutor.submit(()->slf.setResult(this.getInternalRead()));
    try {
      return slf.get();
    } catch (InterruptedException | ExecutionException e) {
      throw new RuntimeException("Bad problems!", e);
    }
  }

  private ReuseableMergedByteBuffers getInternalRead() {
    ReuseableMergedByteBuffers mbb = readBuffers.duplicateAndClean();
    if(mbb.remaining() >= maxBufferSize) {
      se.setClientOperations(this);
    }
    return mbb;
  }