(&mut self)
| 406 | /// Subscribe to [`NetworkEvent`]s. |
| 407 | #[tracing::instrument(skip(self))] |
| 408 | pub fn network_events(&mut self) -> Receiver<NetworkEvent> { |
| 409 | let (s, r) = channel(512); |
| 410 | self.network_events |
| 411 | .push((Arc::new(AtomicBool::new(true)), s)); |
| 412 | r |
| 413 | } |
| 414 | |
| 415 | fn destroy_session(&mut self, ctx: u64, response_channel: oneshot::Sender<Result<()>>) { |
| 416 | if let Some(bs) = self.swarm.behaviour().bitswap.as_ref() { |