ReadWriteStream.java

// Basic impl
public class ReadWriteStream implements ReadStream<Buffer>, WriteStream<Buffer> {

  private Handler<Buffer> dataHandler;
  private Handler<Void> endHandler;
  private Handler<Void> drainHandler;
  private boolean paused;

  @Override
  public ReadWriteStream exceptionHandler(Handler<Throwable> handler) {
    return this;
  }

  @Override
  public ReadWriteStream handler(Handler<Buffer> handler) {
    dataHandler = handler;
    return this;
  }

  @Override
  public ReadWriteStream pause() {
    paused = true;
    return this;
  }

  @Override
  public ReadWriteStream resume() {
    paused = false;
    if (drainHandler != null) {
      drainHandler.handle(null);
    }
    return this;
  }

  @Override
  public ReadWriteStream endHandler(Handler<Void> handler) {
    endHandler = handler;
    return this;
  }

  @Override
  public ReadWriteStream write(Buffer data) {
    if (dataHandler != null) {
      dataHandler.handle(data);
    }
    return this;
  }

  @Override
  public void end() {
    if (endHandler != null) {
      endHandler.handle(null);
    }
  }

  @Override
  public ReadWriteStream setWriteQueueMaxSize(int maxSize) {
    return this;
  }

  @Override
  public boolean writeQueueFull() {
    return paused;
  }

  @Override
  public ReadWriteStream drainHandler(Handler<Void> handler) {
    drainHandler = handler;
    return this;
  }
}