LineBufferedAdapter

Adapter for connections with a line-based protocol. Splits data stream into delimiter-separated lines.

class LineBufferedAdapter : ConnectionAdapter {

string delimiter;

size_t maxLength;

this(IConnection next);

void send(string line);

protected

Data inBuffer;

void onReadData(Data data);

bool processLine(size_t index);

void onDisconnect(string reason, DisconnectType type);

}

Constructors

this this(IConnection next): Undocumented in source.

Members

Functions

onDisconnect void onDisconnect(string reason, DisconnectType type): Undocumented in source. Be warned that the author may not have intended to support it.
onReadData void onReadData(Data data): Called when data has been received.
processLine bool processLine(size_t index): Undocumented in source. Be warned that the author may not have intended to support it.
send void send(string line): Append a line to the send buffer.

Variables

delimiter string delimiter;: The protocol's line delimiter.
inBuffer Data inBuffer;: The receive buffer.
maxLength size_t maxLength;: Maximum line length (0 means unlimited).

Inherited Members

From ConnectionAdapter

next IConnection next;: The next connection in the chain (towards the raw transport).
state ConnectionState state [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
send void send(Data[] data, int priority): Queue Data for sending.
send alias send = IConnection.send: Undocumented in source.
disconnect void disconnect(string reason, DisconnectType type): Terminate the connection.
onConnect void onConnect(): Undocumented in source. Be warned that the author may not have intended to support it.
onReadData void onReadData(Data data): Undocumented in source. Be warned that the author may not have intended to support it.
onDisconnect void onDisconnect(string reason, DisconnectType type): Undocumented in source. Be warned that the author may not have intended to support it.
onBufferFlushed void onBufferFlushed(): Undocumented in source. Be warned that the author may not have intended to support it.
handleConnect ConnectHandler handleConnect [@property setter]: Callback for when a connection has been established.
connectHandler ConnectHandler connectHandler;: Undocumented in source.
handleReadData ReadDataHandler handleReadData [@property setter]: Callback setter for when new data is read.
readDataHandler ReadDataHandler readDataHandler;: Undocumented in source.
handleDisconnect DisconnectHandler handleDisconnect [@property setter]: Callback setter for when a connection was closed.
disconnectHandler DisconnectHandler disconnectHandler;: Undocumented in source.
handleBufferFlushed BufferFlushedHandler handleBufferFlushed [@property setter]: Callback setter for when all queued data has been written.
bufferFlushedHandler BufferFlushedHandler bufferFlushedHandler;: Undocumented in source.

LineBufferedAdapter

Constructors

Members

Functions

Variables

Inherited Members

From ConnectionAdapter

Meta

Source