(&mut self, _: &Context)
| 33 | async fn finalize(&mut self) {} |
| 34 | |
| 35 | async fn exec(&mut self, _: &Context) -> Result<()> { |
| 36 | if let Ok(envelope) = self.inp.recv::<u32>().await { |
| 37 | self.out.send(envelope).await.ok(); |
| 38 | } |
| 39 | Ok(()) |
| 40 | } |
| 41 | } |
| 42 | |
| 43 | node_register!("Transport", Transport); |