(&mut self, py: Python)
| 37 | #[pymethods] |
| 38 | impl Graph { |
| 39 | fn wait(&mut self, py: Python) { |
| 40 | self.inps.clear(); |
| 41 | self.outs.clear(); |
| 42 | if let Some(graph) = self.graph.take() { |
| 43 | graph.stop(); |
| 44 | } |
| 45 | if let Some(handle) = self.handle.take() { |
| 46 | py.allow_threads(|| { |
| 47 | flow_rs::rt::task::block_on(async { |
| 48 | handle.await.unwrap(); |
| 49 | }); |
| 50 | }); |
| 51 | } |
| 52 | } |
| 53 | |
| 54 | fn inputs(&self) -> Vec<&str> { |
| 55 | self.inps.keys().map(|x| x.as_str()).collect() |
no test coverage detected