Trait acto_rs::Task [−] [src]

pub trait Task {
    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: ReceiverChannelId) -> Option<(ChannelId, SenderName)>;
    fn input_channel_pos(&self, ch_id: ReceiverChannelId) -> ChannelPosition;
    fn output_channel_pos(&self, ch_id: SenderChannelId) -> ChannelPosition;
}

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: ReceiverChannelId) -> Option<(ChannelId, SenderName)>`

`fn input_channel_pos(&self, ch_id: ReceiverChannelId) -> ChannelPosition`

`fn output_channel_pos(&self, ch_id: SenderChannelId) -> ChannelPosition`

Implementors

impl<Output: 'static + Send> Task for SourceWrap<Output>
impl<Input: Send, Output: Send> Task for FilterWrap<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<Input: Send> Task for SinkWrap<Input>
impl<Input: Send, Output: Send> Task for ScatterWrap<Input, Output>
impl<Input: Send, Output: Send> Task for GatherWrap<Input, Output>