Package net.bluemind.core.rest.http.internal

Class BodyGeneratorStream

java.lang.Object
org.asynchttpclient.request.body.generator.QueueBasedFeedableBodyGenerator<ConcurrentLinkedQueue<org.asynchttpclient.request.body.generator.BodyChunk>>
net.bluemind.core.rest.http.internal.BodyGeneratorStream
All Implemented Interfaces:
io.vertx.core.streams.StreamBase, io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>, org.asynchttpclient.request.body.generator.BodyGenerator, org.asynchttpclient.request.body.generator.FeedableBodyGenerator
public class BodyGeneratorStream extends org.asynchttpclient.request.body.generator.QueueBasedFeedableBodyGenerator<ConcurrentLinkedQueue<org.asynchttpclient.request.body.generator.BodyChunk>> implements org.asynchttpclient.request.body.generator.BodyGenerator, io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

  • Field Summary Link icon

    Fields inherited from class org.asynchttpclient.request.body.generator.QueueBasedFeedableBodyGenerator Link icon

    queue

  • Constructor Summary Link icon

    Constructors
    Constructor
    Description
    BodyGeneratorStream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> bodyStream)
     

  • Method Summary Link icon

    Modifier and Type
    Method
    Description
    org.asynchttpclient.request.body.Body
    createBody()
     
    BodyGeneratorStream
    drainHandler(io.vertx.core.Handler<Void> handler)
     
    io.vertx.core.Future<Void>
    end()
     
    void
    end(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
     
    BodyGeneratorStream
    exceptionHandler(io.vertx.core.Handler<Throwable> handler)
     
    protected boolean
    offer(org.asynchttpclient.request.body.generator.BodyChunk chunk)
     
    BodyGeneratorStream
    setWriteQueueMaxSize(int maxSize)
     
    io.vertx.core.Future<Void>
    write(io.vertx.core.buffer.Buffer data)
     
    void
    write(io.vertx.core.buffer.Buffer data, io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
     
    boolean
    writeQueueFull()
     

    Methods inherited from class org.asynchttpclient.request.body.generator.QueueBasedFeedableBodyGenerator Link icon

    feed, setListener

    Methods inherited from class java.lang.Object Link icon

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

    Methods inherited from interface io.vertx.core.streams.WriteStream Link icon

    end, end

  • Constructor Details Link icon

    • BodyGeneratorStream Link icon

      public BodyGeneratorStream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> bodyStream)

  • Method Details Link icon

    • createBody Link icon

      public org.asynchttpclient.request.body.Body createBody()
      Specified by:
      createBody in interface org.asynchttpclient.request.body.generator.BodyGenerator
      Overrides:
      createBody in class org.asynchttpclient.request.body.generator.QueueBasedFeedableBodyGenerator<ConcurrentLinkedQueue<org.asynchttpclient.request.body.generator.BodyChunk>>

    • offer Link icon

      protected boolean offer(org.asynchttpclient.request.body.generator.BodyChunk chunk)
      Specified by:
      offer in class org.asynchttpclient.request.body.generator.QueueBasedFeedableBodyGenerator<ConcurrentLinkedQueue<org.asynchttpclient.request.body.generator.BodyChunk>>

    • exceptionHandler Link icon

      public BodyGeneratorStream exceptionHandler(io.vertx.core.Handler<Throwable> handler)
      Specified by:
      exceptionHandler in interface io.vertx.core.streams.StreamBase
      Specified by:
      exceptionHandler in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

    • setWriteQueueMaxSize Link icon

      public BodyGeneratorStream setWriteQueueMaxSize(int maxSize)
      Specified by:
      setWriteQueueMaxSize in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

    • writeQueueFull Link icon

      public boolean writeQueueFull()
      Specified by:
      writeQueueFull in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

    • drainHandler Link icon

      public BodyGeneratorStream drainHandler(io.vertx.core.Handler<Void> handler)
      Specified by:
      drainHandler in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

    • write Link icon

      public io.vertx.core.Future<Void> write(io.vertx.core.buffer.Buffer data)
      Specified by:
      write in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

    • write Link icon

      public void write(io.vertx.core.buffer.Buffer data, io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
      Specified by:
      write in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

    • end Link icon

      public io.vertx.core.Future<Void> end()
      Specified by:
      end in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

    • end Link icon

      public void end(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
      Specified by:
      end in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>