Trait Task

pub trait Task {
    // Required methods
    fn execute(&mut self) -> Schedule;
    fn name(&self) -> &String;
    fn input_count(&self) -> usize;
    fn output_count(&self) -> usize;
    fn input_id(&self, ch_id: usize) -> Option<ChannelId>;
    fn tx_count(&self, ch_id: usize) -> usize;

    // Provided method
    fn output_id(&self, ch_id: usize) -> Option<ChannelId> { ... }
}

Required Methods

fn execute(&mut self) -> Schedule

fn name(&self) -> &String

fn input_count(&self) -> usize

fn output_count(&self) -> usize

fn input_id(&self, ch_id: usize) -> Option<ChannelId>

fn tx_count(&self, ch_id: usize) -> usize

Provided Methods

fn output_id(&self, ch_id: usize) -> Option<ChannelId>

Implementors

impl<Input: Send> Task for SinkWrap<Input>

impl<Input: Send, Output: Send> Task for FilterWrap<Input, Output>

impl<Input: Send, Output: Send> Task for GatherWrap<Input, Output>

impl<Input: Send, Output: Send> Task for ScatterWrap<Input, Output>

impl<Input: Send, OutputA: Send, OutputB: Send> Task for YSplitWrap<Input, OutputA, OutputB>

impl<InputA: Send, InputB: Send, Output: Send> Task for YMergeWrap<InputA, InputB, Output>

impl<Output: 'static + Send> Task for SourceWrap<Output>