Trait acto_rs::Task [−] [src]

pub trait Task {
    fn execute(&mut self, stop: &mut bool);
    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, stop: &mut bool)`

`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<OutputValue: Send, OutputError: Send> Task for SourceWrap<OutputValue, OutputError>
impl<InputValue: Send, InputError: Send, OutputValue: Send, OutputError: Send> Task for FilterWrap<InputValue, InputError, OutputValue, OutputError>
impl<InputValue: Send, InputError: Send, OutputValueA: Send, OutputErrorA: Send, OutputValueB: Send, OutputErrorB: Send> Task for YSplitWrap<InputValue, InputError, OutputValueA, OutputErrorA, OutputValueB, OutputErrorB>
impl<InputValueA: Send, InputErrorA: Send, InputValueB: Send, InputErrorB: Send, OutputValue: Send, OutputError: Send> Task for YMergeWrap<InputValueA, InputErrorA, InputValueB, InputErrorB, OutputValue, OutputError>
impl<InputValue: 'static + Send, InputError: 'static + Send> Task for SinkWrap<InputValue, InputError>
impl<InputValue: Send, InputError: Send, OutputValue: Send, OutputError: Send> Task for ScatterWrap<InputValue, InputError, OutputValue, OutputError>
impl<InputValue: Send, InputError: Send, OutputValue: Send, OutputError: Send> Task for GatherWrap<InputValue, InputError, OutputValue, OutputError>