Struct ThreadedDriver 

pub struct ThreadedDriver;

Available on crate feature std only.

Background-thread pipeline driver. Spawns a single OS thread that runs the pipeline; the calling thread blocks on join.

Implementations

impl ThreadedDriver

pub const fn new() -> Self

Construct a new threaded driver.

pub 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 on a spawned thread.

Errors

Returns the first error produced by the source, any stage, or the sink. Returns Error::Cancelled if the worker thread panics.

Trait Implementations

impl Clone for ThreadedDriver

fn clone(&self) -> ThreadedDriver

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ThreadedDriver

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

Formats the value using the given formatter.

impl Default for ThreadedDriver

fn default() -> ThreadedDriver

Returns the “default value” for a type.

impl Driver for ThreadedDriver

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 ThreadedDriver