Searched defs:cancel_tx (Results 1 – 3 of 3) sorted by relevance
244 fn push_pending(&mut self, key: K, svc: S, (cancel_tx, cancel_rx): CancelPair) { in push_pending()278 let cancel_tx = self.pending_cancel_txs.swap_remove(&key); in poll_pending() localVariable296 let cancel_tx = self.pending_cancel_txs.swap_remove(&key); in poll_pending() localVariable
400 auto cancel_tx = std::make_unique<grpc_binder::Transaction>( in perform_stream_op_locked() local
404 auto cancel_tx = std::make_unique<grpc_binder::Transaction>( in perform_stream_op_locked() local