Struct TcpCommunicationChannels

pub struct TcpCommunicationChannels {
    pub rx_tcp_communication_from_relay_manager_opt: Option<AquaReceiver<InternalCommand>>,
    pub rx_tcp_communication_from_sensor_manager_opt: Option<AquaReceiver<InternalCommand>>,
    pub tx_tcp_communication_to_sensor_manager_opt: Option<AquaSender<Result<f32, TcpCommunicationError>>>,
    pub rx_tcp_communication_from_tank_level_switch_opt: Option<AquaReceiver<InternalCommand>>,
    pub tx_tcp_communication_to_tank_level_switch_opt: Option<AquaSender<Result<f32, TcpCommunicationError>>>,
    pub tx_tcp_communication_to_signal_handler: AquaSender<bool>,
    pub rx_tcp_communication_from_signal_handler: AquaReceiver<InternalCommand>,
}

Struct collects the channels for communication with other threads.

Fields

rx_tcp_communication_from_relay_manager_opt: Option<AquaReceiver<InternalCommand>>

Receiver part of the channel for communication from the relay manager wrapped in Option type

rx_tcp_communication_from_sensor_manager_opt: Option<AquaReceiver<InternalCommand>>

Receiver part of the channel for communication from the sensor manager wrapped in Option type

tx_tcp_communication_to_sensor_manager_opt: Option<AquaSender<Result<f32, TcpCommunicationError>>>

Sender part of the channel for communication to sensor manager wrapped in Option type

rx_tcp_communication_from_tank_level_switch_opt: Option<AquaReceiver<InternalCommand>>

Receiver part of the channel for communication from tank level switch wrapped in Option type

tx_tcp_communication_to_tank_level_switch_opt: Option<AquaSender<Result<f32, TcpCommunicationError>>>

Sender part of the channel for communication to tank level switch wrapped in Option type

tx_tcp_communication_to_signal_handler: AquaSender<bool>

Sender part of the channel for communication to the signal handler

rx_tcp_communication_from_signal_handler: AquaReceiver<InternalCommand>

Receiver part of the channel for communication from the signal handler

Implementations

impl TcpCommunicationChannels

pub fn receive_from_relay_manager( &mut self, ) -> Option<Result<InternalCommand, AquaChannelError>>

Receives a command from the relay manager if the channel exists.

pub fn receive_from_sensor_manager( &mut self, ) -> Option<Result<InternalCommand, AquaChannelError>>

Receives a command from the sensor manager if the channel exists.

pub fn send_to_sensor_manager( &mut self, data: Result<f32, TcpCommunicationError>, ) -> Option<Result<(), AquaChannelError>>

Sends a result to the sensor manager if the channel exists.

pub fn receive_from_tank_level_switch( &mut self, ) -> Option<Result<InternalCommand, AquaChannelError>>

Receives a command from the tank level switch if the channel exists.

pub fn send_to_tank_level_switch( &mut self, data: Result<f32, TcpCommunicationError>, ) -> Option<Result<(), AquaChannelError>>

Sends a result to the tank level switch if the channel exists.

pub fn send_to_signal_handler( &mut self, ack: bool, ) -> Result<(), AquaChannelError>

Sends an acknowledgment to the signal handler.

pub fn receive_from_signal_handler( &mut self, ) -> Result<InternalCommand, AquaChannelError>

Receives a command from the signal handler.

Trait Implementations

impl AcknowledgeSignalHandlerTrait for TcpCommunicationChannels

fn send_true_to_signal_handler(&mut self) -> Result<(), AquaChannelError>

Sends the raw acknowledgment message (true) to the SignalHandler.

fn location(&self) -> String

Returns the source location (module path) for logging purposes.

fn acknowledge_signal_handler(&mut self)

Acknowledges the SignalHandler by sending a confirmation message.

impl Display for TcpCommunicationChannels

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.