pub fn forward_bridge_tx(
        &mut self,
        b_out: &str,
        input: channel::Receiver<Message>,
    ) -> anyhow::Result<()> {
        info!("setting communication topic -> {}", b_out);
        let tx: Sender = self.take_bridge_tx(b_out)?;
        let b_out = b_out.to_owned();
        let handle = tokio::task::spawn_blocking(move || loop {
            let msg: Message = input
                .recv()
                .unwrap_or_else(|err| todo!("receiving message from {} failed: {}", b_out, err));
            tx.send(msg).unwrap_or_else(|err| {
                todo!("sending message from topic to {} failed: {}", b_out, err)
            });
        });
        self.pipes.push(handle);
        Ok(())
    }
/// Forward all messages from crossbeam Receiver to module b_out
/// Spawns pipe handler in a tokio blocking task thread
/// - b_out name of outgoing bridge from Self::bridges
Forward all messages from crossbeam Receiver to module b_out
Spawns pipe handler in a tokio blocking task thread
b_out name of outgoing bridge from Self::bridges
Forward all messages from crossbeam Receiver to module b_out Spawns pipe handler in a tokio blocking task thread b_out name of outgoing bridge from Self :: bridges
pub fn forward_bridge_tx(
        &mut self,
        b_out: &str,
        input: channel::Receiver<Message>,
    ) -> anyhow::Result<()> {
        info!("setting communication topic -> {}", b_out);
        let tx: Sender = self.take_bridge_tx(b_out)?;
        let b_out = b_out.to_owned();
        let handle = tokio::task::spawn_blocking(move || loop {
            let msg: Message = input
                .recv()
                .unwrap_or_else(|err| todo!("receiving message from {} failed: {}", b_out, err));
            tx.send(msg).unwrap_or_else(|err| {
                todo!("sending message from topic to {} failed: {}", b_out, err)
            });
        });
        self.pipes.push(handle);
        Ok(())
    }
pub fn forward_bridge_tx ( & mut self , b_out : & str , input : channel :: Receiver < Message > , ) -> anyhow :: Result < ( ) > { info ! ( " " b_out ) ; let tx : Sender = self . take_bridge_tx ( b_out ) ? ; let b_out = b_out . to_owned ( ) ; let handle = tokio :: task :: spawn_blocking ( move | | loop { let msg : Message = input . recv ( ) . unwrap_or_else ( | err | todo ! ( " " b_out err ) ) ; tx . send ( msg ) . unwrap_or_else ( | err | { todo ! ( " " b_out err ) } ) ; } ) ; self . pipes . push ( handle ) ; Ok ( ( ) ) }
Forward all messages from crossbeam Receiver to module b_out
Spawns pipe handler in a tokio blocking task thread
 b_out name of outgoing bridge from Self::bridges
Forward all messages from crossbeam Receiver to module b_out Spawns pipe handler in a tokio blocking task thread b_out name of outgoing bridge from Self :: bridges
&mut self
b_out
&str
input
channel::Receiver<Message>
&mut self
b_out
&str
input
channel::Receiver<Message>