public interface WriteStream<T> extends StreamBase
Any class that implements this interface can be used by a Pump to pump data from a ReadStream
to it.
original non RX-ified interface using Vert.x codegen.| Modifier and Type | Method and Description |
|---|---|
WriteStream<T> |
drainHandler(Handler<Void> handler)
Set a drain handler on the stream.
|
WriteStream<T> |
exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the write stream.
|
Object |
getDelegate() |
static <T> WriteStream<T> |
newInstance(WriteStream arg) |
WriteStream<T> |
setWriteQueueMaxSize(int maxSize)
Set the maximum size of the write queue to
maxSize. |
WriteStream<T> |
write(T data)
Write some data to the stream.
|
boolean |
writeQueueFull()
This will return
true if there are more bytes in the write queue than the value set using setWriteQueueMaxSize(int) |
newInstanceObject getDelegate()
getDelegate in interface StreamBaseWriteStream<T> exceptionHandler(Handler<Throwable> handler)
exceptionHandler in interface StreamBasehandler - the exception handlerWriteStream<T> write(T data)
writeQueueFull() method before writing. This is done automatically if using a Pump.data - the data to writeWriteStream<T> setWriteQueueMaxSize(int maxSize)
maxSize. You will still be able to write to the stream even
if there is more than maxSize bytes in the write queue. This is used as an indicator by classes such as
Pump to provide flow control.maxSize - the max size of the write streamboolean writeQueueFull()
true if there are more bytes in the write queue than the value set using setWriteQueueMaxSize(int)WriteStream<T> drainHandler(Handler<Void> handler)
Pump for an example of this being used.handler - the handlerstatic <T> WriteStream<T> newInstance(WriteStream arg)
Copyright © 2015. All rights reserved.