| Overview |  |
Methods for sending messages to the sink.
Sink messages are delivered as three record types:#pipe_result{}, #pipe_log{}, and #pipe_eoi{}.
| eoi/1 | Send an end-of-inputs message to the sink (used by fittings). |
| log/3 | Send a log message to the sink (used by worker processes and fittings). |
| result/3 | Send a result to the sink (used by worker processes). |
eoi(Sink::riak_pipe:fitting()) -> #pipe_eoi{}
Send an end-of-inputs message to the sink (used by fittings).
The message is delivered as a #pipe_eoi{} record in the sink
process's mailbox.
log(From::term(), Sink::riak_pipe:fitting(), Msg::term()) -> #pipe_log{}
Send a log message to the sink (used by worker processes and
fittings). The message is delivered as a #pipe_log{} record
in the sink process's mailbox.
result(From::term(), Sink::riak_pipe:fitting(), Output::term()) -> #pipe_result{}
Send a result to the sink (used by worker processes). The
result is delivered as a #pipe_result{} record in the sink
process's mailbox.
Generated by EDoc, Aug 5 2012, 06:58:52.