Method exec

flow-rs/tests/nodes_ext.rs:18–41

(&mut self, _: &Context)

    async fn initialize(&mut self, _: ResourceCollection) {}
    async fn finalize(&mut self) {}
    async fn exec(&mut self, _: &Context) -> Result<()> {
        let mut recv_a = FuturesUnordered::new();
        recv_a.push(self.a.recv_any());
        let mut recv_b = FuturesUnordered::new();
        recv_b.push(self.b.recv_any());
        loop {
            select! {
                a = recv_a.select_next_some() => {
                    if let Ok(a) = a {
                        self.c.send_any(a).await.ok();
                        recv_a.push(self.a.recv_any());
                    }
                }
                b = recv_b.select_next_some() => {
                    if let Ok(b) = b {
                        self.c.send_any(b).await.ok();
                        recv_b.push(self.b.recv_any());
                    }
                }
                complete => break,
            }
        }
        Ok(())
    }
}

node_register!("BinaryOpr", BinaryOpr);