Struct cernan::source::RunnableSource

pub struct RunnableSource<S, SConfig> where
    S: Send + Source<SConfig>,
    SConfig: 'static + Send + Clone,  { /* fields omitted */ }

Generic interface used to capture global source configuration parameters as well as source specific parameters.

Stored configuration is consumed when the source is spawned, resulting in a new thread which executes the given source.

Methods

impl<S, SConfig> RunnableSource<S, SConfig> where
    S: Send + Source<SConfig>,
    SConfig: 'static + Send + Clone, 

pub fn new(chans: Channel, config: SConfig) -> Self

Constructs a new RunnableSource.

pub fn run(self) -> ThreadHandle

Spawns a thread corresponding to the given RunnableSource, consuming the given RunnableSource in the process.

Trait Implementations