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

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

    queue

  • Constructor Summary

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

  • Method Summary

    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

    feed, setListener

    Methods inherited from class java.lang.Object

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

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

    end, end

  • Constructor Details

    • BodyGeneratorStream

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

  • Method Details

    • createBody

      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

      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

      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

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

    • writeQueueFull

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

    • drainHandler

      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

      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

      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

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

    • end

      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>