pub struct FeedChannels {
pub tx_feed_to_relay_manager: AquaSender<InternalCommand>,
pub rx_feed_from_relay_manager: AquaReceiver<bool>,
pub tx_feed_to_signal_handler: AquaSender<bool>,
pub rx_feed_from_signal_handler: AquaReceiver<InternalCommand>,
pub rx_feed_from_messaging_opt: Option<AquaReceiver<InternalCommand>>,
}Expand description
Struct collects the channels for communication between the feed control and the other components.
Fields§
§tx_feed_to_relay_manager: AquaSender<InternalCommand>Sender part of the channel for communication to relay manager
rx_feed_from_relay_manager: AquaReceiver<bool>Receiver part of the channel for communication from the relay manager
tx_feed_to_signal_handler: AquaSender<bool>Sender part of the channel for communication to the signal handler
rx_feed_from_signal_handler: AquaReceiver<InternalCommand>Receiver part of the channel for communication from the signal handler
rx_feed_from_messaging_opt: Option<AquaReceiver<InternalCommand>>Receiver part of the channel wrapped in Option for communication from the messaging
Implementations§
Source§impl FeedChannels
impl FeedChannels
Sourcepub fn send_to_relay_manager(
&mut self,
command: InternalCommand,
) -> Result<(), AquaChannelError>
pub fn send_to_relay_manager( &mut self, command: InternalCommand, ) -> Result<(), AquaChannelError>
Sends a command to the relay manager.
Sourcepub fn receive_from_relay_manager(&mut self) -> Result<bool, AquaChannelError>
pub fn receive_from_relay_manager(&mut self) -> Result<bool, AquaChannelError>
Receives a response from the relay manager.
Sourcepub fn send_to_signal_handler(
&mut self,
ack: bool,
) -> Result<(), AquaChannelError>
pub fn send_to_signal_handler( &mut self, ack: bool, ) -> Result<(), AquaChannelError>
Sends an acknowledgment to the signal handler.
Trait Implementations§
Source§impl AcknowledgeSignalHandlerTrait for FeedChannels
impl AcknowledgeSignalHandlerTrait for FeedChannels
Source§fn send_true_to_signal_handler(&mut self) -> Result<(), AquaChannelError>
fn send_true_to_signal_handler(&mut self) -> Result<(), AquaChannelError>
Source§fn location(&self) -> String
fn location(&self) -> String
Returns the source location (module path) for logging purposes. Read more
Source§fn acknowledge_signal_handler(&mut self)
fn acknowledge_signal_handler(&mut self)
Acknowledges the
SignalHandler by sending a confirmation message. Read moreAuto Trait Implementations§
impl Freeze for FeedChannels
impl RefUnwindSafe for FeedChannels
impl Send for FeedChannels
impl !Sync for FeedChannels
impl Unpin for FeedChannels
impl UnwindSafe for FeedChannels
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more