WriteStream

Undocumented in source.

interface WriteStream : StreamBase (

T

) {

WriteStream!T exceptionHandler(Handler!Throwable var1);

Future!Void write(T data);

void write(T data, VoidAsyncHandler handler);

Future!Void end();

void end(VoidAsyncHandler var1);

Future!Void end(T data);

void end(T data, VoidAsyncHandler handler);

WriteStream!T setWriteQueueMaxSize(int var1);

bool writeQueueFull();

WriteStream!T drainHandler(Handler!Void var1);

}

Members

Functions

drainHandler WriteStream!T drainHandler(Handler!Void var1): Undocumented in source.
end Future!Void end(): Ends the stream. <p> Once the stream has ended, it cannot be used any more.
end void end(VoidAsyncHandler var1): Same as {@link #end()} but with an {@code handler} called when the operation completes
end Future!Void end(T data): Undocumented in source. Be warned that the author may not have intended to support it.
end void end(T data, VoidAsyncHandler handler): Undocumented in source. Be warned that the author may not have intended to support it.
exceptionHandler WriteStream!T exceptionHandler(Handler!Throwable var1): Undocumented in source.
setWriteQueueMaxSize WriteStream!T setWriteQueueMaxSize(int var1): Undocumented in source.
write Future!Void write(T data): Write some data to the stream. The data is put on an internal write queue, and the write actually happens asynchronously. To avoid running out of memory by putting too much on the write queue, check the {@link #writeQueueFull} method before writing. This is done automatically if using a {@link Pump}.
write void write(T data, VoidAsyncHandler handler): Same as {@link #write(T)} but with an {@code handler} called when the operation completes
writeQueueFull bool writeQueueFull(): Undocumented in source.

Inherited Members

From StreamBase

exceptionHandler StreamBase exceptionHandler(Handler!Throwable var1): Undocumented in source.

Meta

Source

See Implementation

hunt amqp client WriteStream interfaces

WriteStream