WriteStream

Undocumented in source.

interface WriteStream : StreamBase (

T

) {

WriteStream!T exceptionHandler(Handler!Throwable var1);

void write(T var1, Handler!Void var2);

void end(Handler!Void var1);

void end(T data, Handler!Void 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 void end(Handler!Void var1): Undocumented in source.
end void end(T data, Handler!Void 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 void write(T var1, Handler!Void var2): Undocumented in source.
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