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.