net.bluemind.core.rest.http.internal

Class BodyGeneratorStream

java.lang.Object

org.asynchttpclient.request.body.generator.QueueBasedFeedableBodyGenerator<java.util.concurrent.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<java.util.concurrent.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 and Description
BodyGeneratorStream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> bodyStream)

Method Summary

Modifier and Type	Method and Description
org.asynchttpclient.request.body.Body	createBody()
BodyGeneratorStream	drainHandler(io.vertx.core.Handler<java.lang.Void> handler)
void	end()
void	end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)
BodyGeneratorStream	exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)
protected boolean	offer(org.asynchttpclient.request.body.generator.BodyChunk chunk)
BodyGeneratorStream	setWriteQueueMaxSize(int maxSize)
BodyGeneratorStream	write(io.vertx.core.buffer.Buffer data)
io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>	write(io.vertx.core.buffer.Buffer data, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.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 Detail

BodyGeneratorStream

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

Method Detail

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<java.util.concurrent.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<java.util.concurrent.ConcurrentLinkedQueue<org.asynchttpclient.request.body.generator.BodyChunk>>

exceptionHandler

public BodyGeneratorStream exceptionHandler(io.vertx.core.Handler<java.lang.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<java.lang.Void> handler)

Specified by:

drainHandler in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

write

public BodyGeneratorStream write(io.vertx.core.buffer.Buffer data)

Specified by:

write in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

write

public io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer> write(io.vertx.core.buffer.Buffer data,
                                                                            io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)

Specified by:

write in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

end

public 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<java.lang.Void>> handler)

Specified by:

end in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>