net.bluemind.core.rest.vertx

Class BusWriteStream

java.lang.Object

net.bluemind.core.rest.vertx.BusWriteStream

All Implemented Interfaces:

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

public class BusWriteStream
extends java.lang.Object
implements io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	queueFull
protected io.vertx.core.eventbus.Message<?>	replyEvent
protected java.lang.String	streamAddress

Constructor Summary

Constructors

Constructor and Description
BusWriteStream(io.vertx.core.Vertx vertx, java.lang.String streamAddress)

Method Summary

Modifier and Type	Method and Description
io.vertx.core.Handler<io.vertx.core.eventbus.Message<java.lang.Void>>	busHandler()
void	complete()
BusWriteStream	drainHandler(io.vertx.core.Handler<java.lang.Void> handler)
io.vertx.core.Future<java.lang.Void>	end()
void	end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)
BusWriteStream	exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)
BusWriteStream	setWriteQueueMaxSize(int maxSize)
io.vertx.core.Future<java.lang.Void>	write(io.vertx.core.buffer.Buffer data)
void	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 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

Field Detail

streamAddress

protected java.lang.String streamAddress

queueFull

protected boolean queueFull

replyEvent

protected io.vertx.core.eventbus.Message<?> replyEvent

Constructor Detail

BusWriteStream

public BusWriteStream(io.vertx.core.Vertx vertx,
                      java.lang.String streamAddress)

Method Detail

complete

public void complete()

exceptionHandler

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

Specified by:

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

busHandler

public io.vertx.core.Handler<io.vertx.core.eventbus.Message<java.lang.Void>> busHandler()

write

public io.vertx.core.Future<java.lang.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<java.lang.Void>> handler)

Specified by:

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

end

public io.vertx.core.Future<java.lang.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>