Struct acto_rs::elem::wrap::ysplit_wrap::YSplitWrap

pub struct YSplitWrap<InputValue: Send, InputError: Send, OutputValueA: Send, OutputErrorA: Send, OutputValueB: Send, OutputErrorB: Send> { /* fields omitted */ }

Trait Implementations

impl<InputValue: Send, InputError: Send, OutputValueA: Send, OutputErrorA: Send, OutputValueB: Send, OutputErrorB: Send> IdentifiedInput for YSplitWrap<InputValue, InputError, OutputValueA, OutputErrorA, OutputValueB, OutputErrorB>

fn get_input_id(
    &self,
    ch_id: ReceiverChannelId
) -> Option<(ChannelId, SenderName)>

impl<InputValue: Send, InputError: Send, OutputValueA: Send, OutputErrorA: Send, OutputValueB: Send, OutputErrorB: Send> InputCounter for YSplitWrap<InputValue, InputError, OutputValueA, OutputErrorA, OutputValueB, OutputErrorB>

fn get_rx_count(&self, ch_id: ReceiverChannelId) -> usize

impl<InputValue: Send, InputError: Send, OutputValueA: Send, OutputErrorA: Send, OutputValueB: Send, OutputErrorB: Send> OutputCounter for YSplitWrap<InputValue, InputError, OutputValueA, OutputErrorA, OutputValueB, OutputErrorB>

fn get_tx_count(&self, ch_id: SenderChannelId) -> usize

impl<InputValue: Send, InputError: Send, OutputValueA: Send, OutputErrorA: Send, OutputValueB: Send, OutputErrorB: Send> Connectable for YSplitWrap<InputValue, InputError, OutputValueA, OutputErrorA, OutputValueB, OutputErrorB>

type InputValue = InputValue

type InputError = InputError

fn input(&mut self) -> &mut ChannelWrapper<InputValue, InputError>

fn connect(
    &mut self,
    other: &mut ChannelWrapper<Self::InputValue, Self::InputError>
) -> Result<(), ActorError>

fn disconnect(
    &mut self,
    other: &mut ChannelWrapper<Self::InputValue, Self::InputError>
) -> Result<(), ActorError>

impl<InputValue: Send, InputError: Send, OutputValueA: Send, OutputErrorA: Send, OutputValueB: Send, OutputErrorB: Send> Task for YSplitWrap<InputValue, InputError, OutputValueA, OutputErrorA, OutputValueB, OutputErrorB>

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