Searched refs:out_tx (Results 1 – 1 of 1) sorted by relevance
162 out_tx: mpsc::Sender<Response<T>>, field199 if self.0.out_tx.send(Response::Paused(result)).await.is_err() { in handle()211 .out_tx in handle()254 let (out_tx, out_rx) = mpsc::channel(1); in new()262 let out_tx_clone = out_tx.clone(); in new()265 out_tx, in new()