CumulativeBuffer

Undocumented in source.

class CumulativeBuffer : PromiseIterator!(const(ubyte)[]) {

ubyte[] pending;

DelegatePromise!ItValue pendingReq;

void onDrain();

size_t pendingLength();

Promise!ItValue next(Promise!bool _);

void append(const(ubyte)[] data);

void resolve();

}

Members

Functions

append void append(const(ubyte)[] data): Undocumented in source. Be warned that the author may not have intended to support it.
next Promise!ItValue next(Promise!bool _): Undocumented in source. Be warned that the author may not have intended to support it.
onDrain void onDrain(): Undocumented in source. Be warned that the author may not have intended to support it.
pendingLength size_t pendingLength(): Undocumented in source. Be warned that the author may not have intended to support it.
resolve void resolve(): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

eof bool eof;: Undocumented in source.
pending ubyte[] pending;: Undocumented in source.
pendingReq DelegatePromise!ItValue pendingReq;: Undocumented in source.

Meta

Source

See Implementation

upromised utp classes