Struct cfrp::primitives::input::ReceiverInput [−] [src]

pub struct ReceiverInput<A> {
    // some fields omitted
}

Methods

`impl<A> ReceiverInput<A>`

`fn new(rx: Receiver<A>, tx: SyncSender<Event<A>>) -> ReceiverInput<A>`

Trait Implementations

`impl<A> RunInput for ReceiverInput<A> where A: 'static + Send + Clone`

`fn boxed_no_op(&self) -> Box<NoOp>`

`fn run(self: Box<Self>, idx: usize, txs: Arc<Mutex<Vec<Box<NoOp>>>>)`