GrpcStream

Undocumented in source.

Constructors

this this(bool asyn): Undocumented in source.

Members

Aliases

Callback alias Callback = void delegate(ubyte[] complete): Undocumented in source.

Functions

attachStream void attachStream(Stream stream): Undocumented in source. Be warned that the author may not have intended to support it.
end bool end(): Undocumented in source. Be warned that the author may not have intended to support it.
finish Status finish(): Undocumented in source. Be warned that the author may not have intended to support it.
isAsyn bool isAsyn(): Undocumented in source. Be warned that the author may not have intended to support it.
isClosed bool isClosed(): Undocumented in source. Be warned that the author may not have intended to support it.
onCallBack void onCallBack(ubyte[] complete): Undocumented in source. Be warned that the author may not have intended to support it.
onData void onData(Stream stream, DataFrame frame): Undocumented in source. Be warned that the author may not have intended to support it.
onDataReceived GrpcStream onDataReceived(StreamHandler handler): Undocumented in source. Be warned that the author may not have intended to support it.
onDataTransitQueue void onDataTransitQueue(Stream stream, DataFrame frame): Undocumented in source. Be warned that the author may not have intended to support it.
onDataTransitTask ubyte[] onDataTransitTask(Stream stream, DataFrame frame): Undocumented in source. Be warned that the author may not have intended to support it.
onHeaders void onHeaders(Stream stream, HeadersFrame frame): client status.
pop ubyte[] pop(): Undocumented in source. Be warned that the author may not have intended to support it.
push void push(ubyte[] packet): Undocumented in source. Be warned that the author may not have intended to support it.
reSet void reSet(): Undocumented in source. Be warned that the author may not have intended to support it.
read bool read(OUT obj): Undocumented in source. Be warned that the author may not have intended to support it.
setCallBack void setCallBack(Callback dele): Undocumented in source. Be warned that the author may not have intended to support it.
write void write(IN obj, bool option): Undocumented in source. Be warned that the author may not have intended to support it.
writesdone void writesdone(): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

DataHeadLen ulong DataHeadLen;: Undocumented in source.
_asyn bool _asyn;: Undocumented in source.
_condition Condition _condition;: Undocumented in source.
_dele Callback _dele;: Undocumented in source.
_end bool _end;: Undocumented in source.
_mutex Mutex _mutex;: Undocumented in source.
_queue DList!(ubyte[]) _queue;: Undocumented in source.
_read_buffer EvBuffer!ubyte _read_buffer;: Undocumented in source.
_status Status _status;: Undocumented in source.
_stream Stream _stream;: Undocumented in source.
_write_mutex Mutex _write_mutex;: Undocumented in source.

GrpcStream

Constructors

Members

Aliases

Functions

Variables

Meta

Source