Function dataflow::source::file::send_records[][src]

fn send_records<I, Out, Err>(
    iter: I,
    tx: SyncSender<Result<Out, Error>>,
    activator: Option<SyncActivator>
) where
    I: IntoIterator<Item = Result<Out, Err>>,
    Err: Into<Error>, 
Expand description

Sends a sequence of records and activates a timely operator for each.