Trait cfrp::Run

pub trait Run: Send {
    fn run(self: Box<Self>);
}

Types which can initiate a chain of transformations

Linear transformations are combined into thread-local function compositions - concurrency only applies to forking/merging transformations. Run is required for the 'tip' of each linear transformation.

Required Methods

fn run(self: Box<Self>)

Implementors

• impl<A> Run for Async<A> where A: 'static + Send + Clone
• impl<A> Run for Fork<A> where A: 'static + Clone + Send