StreamTransport

Transport for stream sockets.

version(!D_Ddoc && Posix)

package

class StreamTransport : SocketWatcher , DuplexTransport , SocketTransport {

ReadBuffer!ubyte output;

WriteBuffer!ubyte input;

bool writeReady;

this(SelectorLoop loop, ConnectedSocket socket);

ConnectedSocket socket [@property getter];

Protocol protocol [@property getter];

Protocol protocol [@property setter];

bool isClosing();

void close();

void invoke();

void write(ubyte[] data);

}

Constructors

this this(SelectorLoop loop, ConnectedSocket socket)

Members

Functions

close void close(): Close the transport.
invoke void invoke(): Invokes the watcher callback.
isClosing bool isClosing(): Returns true if the transport is closing or closed.
write void write(ubyte[] data): Write some data to the transport.

Properties

protocol Protocol protocol [@property getter]
protocol Protocol protocol [@property setter]: Switches the protocol.
socket ConnectedSocket socket [@property getter]

Variables

input WriteBuffer!ubyte input;: Undocumented in source.
output ReadBuffer!ubyte output;: Undocumented in source.
writeReady bool writeReady;: Received notification that the underlying socket is write-ready.

Inherited Members

From SocketWatcher

socket_ Socket socket_;: Watched socket.
socket Socket socket [@property getter]

From DuplexTransport

protocol Protocol protocol [@property getter]
protocol Protocol protocol [@property setter]: Switches the protocol.
isClosing bool isClosing(): Returns true if the transport is closing or closed.
close void close(): Close the transport.

From SocketTransport

socket Socket socket [@property getter]

Meta

Source

See Implementation

tanya async event selector classes