code: @Override
  	public Buffer requestBuffer(int minBufferSize) throws IOException {
  		try {
  			return requestBuffer(minBufferSize, false);
  		} catch (InterruptedException e) {
  			throw new IOException("Unexpected InterruptedException while non-blocking buffer request.");
  		}
  	}
docs: -----------------------------------------------------------------------------------------------------------------