FanoutFilter

This is the abstract FanoutFilter base class.

class FanoutFilter : Filter , Filterable {

void incrOwns();

void setNext(Filter f, size_t n);

void setPort(size_t n);

void setNext(Filter* f, size_t n);

void attach(Filter f);

}

Members

Functions

attach void attach(Filter f): Undocumented in source. Be warned that the author may not have intended to support it.
incrOwns void incrOwns(): Increment the number of filters past us that we own
setNext void setNext(Filter* f, size_t n): Undocumented in source. Be warned that the author may not have intended to support it.
setNext void setNext(Filter f, size_t n): Undocumented in source. Be warned that the author may not have intended to support it.
setPort void setPort(size_t n): Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From Filter

write void write(const(ubyte)[] input): Write a portion of a message to this filter.
write void write(const(ubyte)* input, size_t length): Undocumented in source.
send void send(const(ubyte)* input, size_t length)
send void send(ubyte input)
send void send(Vector!(ubyte, ALLOC) input)
send void send(RefCounted!(Vector!(ubyte, ALLOC), ALLOC) input)
send void send(Vector!(ubyte, ALLOC) input, size_t length)
send void send(RefCounted!(Vector!(ubyte, ALLOC), ALLOC) input, size_t length)
newMsg void newMsg(): Start a new message in this and all following filters. Only for internal use, not intended for use in client applications.
finishMsg void finishMsg(): End a new message in this and all following filters. Only for internal use, not intended for use in client applications.
totalPorts size_t totalPorts(): Undocumented in source. Be warned that the author may not have intended to support it.
currentPort size_t currentPort(): Undocumented in source. Be warned that the author may not have intended to support it.
setPort void setPort(size_t new_port): Set the active port
owns size_t owns(): Undocumented in source. Be warned that the author may not have intended to support it.
attach void attach(Filter new_filter): Attach another filter to this one
setNext void setNext(Filter* filters, size_t size)
getNext Filter getNext(): Undocumented in source. Be warned that the author may not have intended to support it.
attachable bool attachable(): Undocumented in source. Be warned that the author may not have intended to support it.
startMsg void startMsg(): Undocumented in source. Be warned that the author may not have intended to support it.
endMsg void endMsg(): Undocumented in source. Be warned that the author may not have intended to support it.
name string name [@property getter]: Undocumented in source.
m_write_queue SecureVector!ubyte m_write_queue;: Undocumented in source.
m_next Vector!Filter m_next;: Undocumented in source.
m_port_num size_t m_port_num;
m_filter_owns size_t m_filter_owns;: Undocumented in source.
m_owned bool m_owned;: Undocumented in source.

From Filterable

name string name [@property getter]
write void write(const(ubyte)* input, size_t length): Write a portion of a message to this filter.
startMsg void startMsg(): Start a new message. Must be closed by endMsg() before another message can be started.
endMsg void endMsg(): Notify that the current message is finished; flush buffers and do end-of-message processing (if any).
attachable bool attachable(): Check whether this filter is an attachable filter.
setNext void setNext(Filter* filters, size_t size)

FanoutFilter

Members

Functions

Inherited Members

From Filter

From Filterable

Meta

Source