Searched refs:pending_confirmation (Results 1 – 2 of 2) sorted by relevance
43 pending_confirmation: mpsc::Receiver<()>, field49 (Self { db, pending_confirmation: rx }, ConfirmationWatcher(tx)) in new()82 let _ = self.pending_confirmation.try_recv(); in send()90 match timeout(Duration::from_secs(30), self.pending_confirmation.recv()).await { in send()
63 pending_confirmation: ConfirmationWatcher, field76 let (indication_handler, pending_confirmation) = IndicationHandler::new(db.clone()); in new()84 pending_confirmation, in new()108 OperationType::Confirmation => self.pending_confirmation.on_confirmation(), in handle_packet()