Trait erdos::dataflow::stream::WriteStreamT

pub trait WriteStreamT<D: Data> {
    fn send(&mut self, msg: Message<D>) -> Result<(), SendError>;
}

Write stream trait which allows specialized implementations of send depending on the serialization library used.

Required methods

fn send(&mut self, msg: Message<D>) -> Result<(), SendError>

Sends a messsage to a channel.

Implementors

impl<'a, D: Data + Deserialize<'a>> WriteStreamT<D> for WriteStream<D>

impl<D> WriteStreamT<D> for IngestStream<D> where
    for<'a> D: Data + Deserialize<'a>,