Fork

This class represents a fork filter, whose purpose is to fork the flow of data. It causes an input message to result in n messages at the end of the filter, where n is the number of forks.

class Fork : FanoutFilter , Filterable {

void write(const(ubyte)* input, size_t length);

void setPort(size_t n);

string name [@property getter];

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

this(Filter* filter_arr, size_t length);

bool attachable();

void startMsg();

void endMsg();

void setNext(Filter* filters, size_t sz);

}

Constructors

this this(Filter f1, Filter f2, Filter f3, Filter f4): Construct a Fork filter with up to four forks.
this this(Filter* filter_arr, size_t length): Construct a Fork 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.
setPort void setPort(size_t n): 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)

Fork

Constructors

Members

Functions

Properties

Inherited Members

From FanoutFilter

From Filterable

Meta

Source