Struct SyncDriver 

pub struct SyncDriver;

Single-threaded pipeline driver.

Implementations

impl SyncDriver

pub const fn new() -> Self

Construct a new sync driver.

pub fn run<S>(self, pipeline: Pipeline<S>) -> Result<RunStats>

where S: Source + 'static, S::Item: 'static, S::Error: 'static,

Drive a pipeline to completion on the calling thread.

This inherent method carries a looser bound than the Driver trait impl: the source and its item/error types do not need to be Send. Use this method directly when the pipeline cannot satisfy Send (for example, a source holding an Rc). When the Send bounds hold, the trait impl and the inherent method behave identically.

Errors

Returns the first error produced by the source, any stage, or the sink.

Trait Implementations

impl Clone for SyncDriver

fn clone(&self) -> SyncDriver

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SyncDriver

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SyncDriver

fn default() -> SyncDriver

Returns the “default value” for a type.

impl Driver for SyncDriver

fn run<S>(self, pipeline: Pipeline<S>) -> Result<RunStats>

where S: Source + Send + 'static, S::Item: Send + 'static, S::Error: Send + 'static,

Drive a pipeline to completion.

impl Copy for SyncDriver