Package net.bluemind.core.rest.vertx

Class VertxStreamProducer

java.lang.Object

net.bluemind.core.rest.vertx.VertxStreamProducer

All Implemented Interfaces:

io.vertx.core.streams.StreamBase, io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>, Stream

public class VertxStreamProducer
extends Object
implements io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>, Stream

Constructor Summary

Constructors

Constructor	Description
VertxStreamProducer(io.vertx.core.Vertx vertx, String streamAddress)

Method Summary

Modifier and Type	Method	Description
void	closed()
protected void	drain()
VertxStreamProducer	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)
VertxStreamProducer	exceptionHandler(io.vertx.core.Handler<Throwable> handler)
void	markQueueFull()
void	sendEnd()
VertxStreamProducer	setWriteQueueMaxSize(int maxSize)
static void	stream(io.vertx.core.Vertx vertx, String controlAdr, io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> bodyStream)
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 java.lang.Object

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

Methods inherited from interface net.bluemind.core.api.Stream

charset, fileName, mime

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

end, end

Constructor Details

VertxStreamProducer

public VertxStreamProducer(io.vertx.core.Vertx vertx,
 String streamAddress)

Method Details

exceptionHandler

public VertxStreamProducer 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 VertxStreamProducer 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 VertxStreamProducer 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>

drain

protected void drain()

sendEnd

public void sendEnd()

stream

public static void stream(io.vertx.core.Vertx vertx,
 String controlAdr,
 io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> bodyStream)

closed

public void closed()

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>

markQueueFull

public void markQueueFull()