public ByteBufInputStream consumeContentAsInputStream() {
    return new ByteBufInputStream(consumeContentAsByteBuf(), true);
  }
@return an {@link InputStream} that contains the data from the chunks received up to this point in time.
ambry-commons/src/main/java/com/github/ambry/commons/RetainingAsyncWritableChannel.java