Chain

This class represents Filter chains. A Filter chain is an ordered concatenation of Filters, the input to a Chain sequentially passes through all the Filters contained in the Chain.

Constructors

this
this(Filter f1, Filter f2, Filter f3, Filter f4)

Construct a chain of up to four filters. The filters are set up in the same order as the arguments.

this
this(Filter* filter_arr, size_t length)

Construct a chain from range of filters

Members

Functions

attachable
bool attachable()
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.
setNext
void setNext(Filter* filters, size_t sz)
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.
write
void write(const(ubyte)* input, size_t length)
Undocumented in source. Be warned that the author may not have intended to support it.

Properties

name
string name [@property getter]
Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From FanoutFilter

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.
setPort
void setPort(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.
attach
void attach(Filter f)
Undocumented in source. Be warned that the author may not have intended to support it.

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)

Meta