TFramedTransport

Framed transport.

All writes go into an in-memory buffer until flush is called, at which point the transport writes the length of the entire binary chunk followed by the data payload. The receiver on the other end then performs a single »fixed-length« read to get the whole message off the wire.

final

class TFramedTransport : TBaseTransport {

this(TTransport transport);

TTransport underlyingTransport();

size_t read(ubyte[] buf);

void write(ubyte[] buf);

void flush();

const(ubyte)[] borrow(ubyte* buf, size_t len);

void consume(size_t len);

}

Constructors

this this(TTransport transport): Constructs a new framed transport.

Members

Functions

borrow const(ubyte)[] borrow(ubyte* buf, size_t len): Undocumented in source. Be warned that the author may not have intended to support it.
close void close(): Undocumented in source. Be warned that the author may not have intended to support it.
consume void consume(size_t len): Undocumented in source. Be warned that the author may not have intended to support it.
flush void flush(): Undocumented in source. Be warned that the author may not have intended to support it.
isOpen bool isOpen(): Undocumented in source. Be warned that the author may not have intended to support it.
open void open(): Undocumented in source. Be warned that the author may not have intended to support it.
peek bool peek(): Undocumented in source. Be warned that the author may not have intended to support it.
read size_t read(ubyte[] buf): Attempts to read data into the given buffer, stopping when the buffer is exhausted or the frame end is reached.
underlyingTransport TTransport underlyingTransport(): Returns the wrapped transport.
write void write(ubyte[] buf): Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From TBaseTransport

isOpen bool isOpen(): Undocumented in source. Be warned that the author may not have intended to support it.
peek bool peek(): Undocumented in source. Be warned that the author may not have intended to support it.
open void open(): Undocumented in source. Be warned that the author may not have intended to support it.
close void close(): Undocumented in source. Be warned that the author may not have intended to support it.
read size_t read(ubyte[] buf): Undocumented in source. Be warned that the author may not have intended to support it.
readAll void readAll(ubyte[] buf): Undocumented in source. Be warned that the author may not have intended to support it.
readEnd size_t readEnd(): Undocumented in source. Be warned that the author may not have intended to support it.
write void write(ubyte[] buf): Undocumented in source. Be warned that the author may not have intended to support it.
writeEnd size_t writeEnd(): Undocumented in source. Be warned that the author may not have intended to support it.
flush void flush(): Undocumented in source. Be warned that the author may not have intended to support it.
borrow const(ubyte)[] borrow(ubyte* buf, size_t len): Undocumented in source. Be warned that the author may not have intended to support it.
consume void consume(size_t len): Undocumented in source. Be warned that the author may not have intended to support it.