Split one push streams into multiple. More...
#include <tpie/pipelining/split.h>
Classes | |
class | sink_impl |
class | source_base |
class | source_impl |
Public Member Functions | |
pipe_begin< factory < source_impl, node_token, std::vector< source_base * > & > > | source () |
pipe_end< termfactory < sink_impl, node_token, std::vector< source_base * > & > > | sink () |
Split one push streams into multiple.
A single pipe can push into sink()
, and multiple pipes can be constructed using source()
. Every element pushed into sink()
will be pushed into every source()
.
T | The type of item pushed |