Method start_loop

flow-rs/src/loader/python/node.rs:113–141

(&mut self, res: ResourceCollection)

    }

    async fn start_loop(&mut self, res: ResourceCollection) {
        self.initialize(res).await;
        let mut empty_n = 0;
        loop {
            self.exec().await;
            if !self.inputs.is_empty() {
                let mut min_empty_n = usize::MAX;
                for ports in self.inputs.values() {
                    for port in ports.storage.values() {
                        min_empty_n = std::cmp::min(min_empty_n, port.empty_n());
                    }
                }

                for _ in empty_n..min_empty_n {
                    for ports in self.outputs.values() {
                        for port in ports.storage.values() {
                            port.send_any(DummyEnvelope {}.seal()).await.ok();
                        }
                    }
                }

                empty_n = min_empty_n;
            }
            if self.is_allinp_closed() {
                break;
            }
        }
        self.close();
    }
}

impl Node for PyNode {