Package co.elastic.clients.transport.rest5_client.low_level

Class BufferedByteConsumer

java.lang.Object
org.apache.hc.core5.http.nio.entity.AbstractBinDataConsumer
org.apache.hc.core5.http.nio.entity.AbstractBinAsyncEntityConsumer<org.apache.hc.core5.http.io.entity.ByteArrayEntity>
co.elastic.clients.transport.rest5_client.low_level.BufferedByteConsumer
All Implemented Interfaces:
org.apache.hc.core5.http.nio.AsyncDataConsumer, org.apache.hc.core5.http.nio.AsyncEntityConsumer<org.apache.hc.core5.http.io.entity.ByteArrayEntity>, org.apache.hc.core5.http.nio.ResourceHolder
public class BufferedByteConsumer extends org.apache.hc.core5.http.nio.entity.AbstractBinAsyncEntityConsumer<org.apache.hc.core5.http.io.entity.ByteArrayEntity>

  • Constructor Summary

    Constructors
    Constructor
    Description
    BufferedByteConsumer(int bufferLimit)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected int
    capacityIncrement()
     
    protected void
    data(ByteBuffer src, boolean endOfStream)
     
    protected org.apache.hc.core5.http.io.entity.ByteArrayEntity
    generateContent()
     
    void
    releaseResources()
     
    protected void
    streamStart(org.apache.hc.core5.http.ContentType contentType)
     

    Methods inherited from class org.apache.hc.core5.http.nio.entity.AbstractBinAsyncEntityConsumer

    completed, failed, getContent, streamStart

    Methods inherited from class org.apache.hc.core5.http.nio.entity.AbstractBinDataConsumer

    consume, streamEnd, updateCapacity

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.apache.hc.core5.http.nio.AsyncDataConsumer

    consume, streamEnd, updateCapacity

  • Constructor Details

    • BufferedByteConsumer

      public BufferedByteConsumer(int bufferLimit)

  • Method Details

    • streamStart

      protected void streamStart(org.apache.hc.core5.http.ContentType contentType)
      Specified by:
      streamStart in class org.apache.hc.core5.http.nio.entity.AbstractBinAsyncEntityConsumer<org.apache.hc.core5.http.io.entity.ByteArrayEntity>

    • capacityIncrement

      protected int capacityIncrement()
      Specified by:
      capacityIncrement in class org.apache.hc.core5.http.nio.entity.AbstractBinDataConsumer

    • data

      protected void data(ByteBuffer src, boolean endOfStream) throws org.apache.hc.core5.http.ContentTooLongException
      Specified by:
      data in class org.apache.hc.core5.http.nio.entity.AbstractBinDataConsumer
      Throws:
      org.apache.hc.core5.http.ContentTooLongException

    • generateContent

      protected org.apache.hc.core5.http.io.entity.ByteArrayEntity generateContent()
      Specified by:
      generateContent in class org.apache.hc.core5.http.nio.entity.AbstractBinAsyncEntityConsumer<org.apache.hc.core5.http.io.entity.ByteArrayEntity>

    • releaseResources

      public void releaseResources()