Struct enande::ProcessBuilder

pub struct ProcessBuilder<TItem, TError> { /* fields omitted */ }

Methods

impl<TItem, TError> ProcessBuilder<TItem, TError> where
    TError: Sized + Send + 'static,
    TItem: Sized + Send + 'static, 

pub fn new() -> Self

pub fn add_stream<'a, TStream, TStreamItem>(
    &'a mut self,
    stream: TStream
) -> &mut Self where
    TStream: Stream<Item = TStreamItem> + Send + Unpin + 'static,
    TStreamItem: Into<TItem>, 

Adds another stream as an input source to this builder.

pub fn add_try<'a, TStream, TStreamItem>(
    &'a mut self,
    stream: TStream
) -> &mut Self where
    TStream: Stream<Item = TStreamItem> + Send + Unpin + 'static,
    TItem: TryFrom<TStreamItem, Error = TError>, 

Adds an input where the Item can be converted into our Item using TryFrom.

pub fn add_try_stream<'a, TStream, TStreamError>(
    &'a mut self,
    stream: TStream
) -> &mut Self where
    TStream: Stream<Item = Result<TItem, TStreamError>> + Send + Unpin + 'static,
    TStreamError: 'static,
    TError: From<TStreamError>, 

Adds an input that contains fails.

pub async fn run<TSink, TSinkError, TProcessor>(
    __arg0: Self,
    sink: TSink,
    processor: TProcessor
) -> Result<(), ()> where
    TProcessor: Processor<Item = TItem, Error = TError>,
    TSink: Sink<TProcessor::ResultItem, Error = TSinkError> + Unpin,
    TError: From<TSinkError> + Send + 'static,