net.bluemind.vertx.testhelper

Class WriteStreamForTests

java.lang.Object

net.bluemind.vertx.testhelper.WriteStreamForTests

All Implemented Interfaces:

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

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

Field Summary

Fields

Modifier and Type	Field and Description
java.util.Queue<io.vertx.core.buffer.Buffer>	received
java.util.concurrent.CompletableFuture<java.lang.Void>	responseFuture

Constructor Summary

Constructors

Constructor and Description
WriteStreamForTests()

Method Summary

Modifier and Type	Method and Description
WriteStreamForTests	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)
WriteStreamForTests	exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)
WriteStreamForTests	setWriteQueueMaxSize(int maxSize)
WriteStreamForTests	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 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

received

public final java.util.Queue<io.vertx.core.buffer.Buffer> received

responseFuture

public final java.util.concurrent.CompletableFuture<java.lang.Void> responseFuture

Constructor Detail

WriteStreamForTests

public WriteStreamForTests()

Method Detail

exceptionHandler

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