(
mut self: Box<Self>,
_: Context,
res: ResourceCollection,
)
| 185 | |
| 186 | impl Actor for PyNode { |
| 187 | fn start( |
| 188 | mut self: Box<Self>, |
| 189 | _: Context, |
| 190 | res: ResourceCollection, |
| 191 | ) -> rt::task::JoinHandle<anyhow::Result<()>> { |
| 192 | if self.exclusive { |
| 193 | flow_rs::rt::task::spawn_blocking(move || { |
| 194 | flow_rs::rt::task::block_on(async move { |
| 195 | self.start_loop(res).await; |
| 196 | }); |
| 197 | Ok(()) |
| 198 | }) |
| 199 | } else { |
| 200 | flow_rs::rt::task::spawn_local(async move { |
| 201 | self.start_loop(res).await; |
| 202 | Ok(()) |
| 203 | }) |
| 204 | } |
| 205 | } |
| 206 | } |
| 207 | |
| 208 | pub fn toml2dict<'a>(py: Python<'a>, args: &toml::value::Table) -> PyResult<&'a PyDict> { |
nothing calls this directly
no test coverage detected