Searched refs:CqFuture (Results 1 – 2 of 2) sorted by relevance
61 pub fn check_alive<T>(f: &CqFuture<T>) -> Result<()> { in check_alive()73 pub struct CqFuture<T> { struct77 impl<T> CqFuture<T> { implementation78 fn new(inner: Arc<Inner<T>>) -> CqFuture<T> { in new()79 CqFuture { inner } in new()83 impl<T> Future for CqFuture<T> { implementation107 pub type BatchFuture = CqFuture<Option<MessageReader>>;125 (CqFuture::new(inner), CallTag::Batch(batch)) in batch_pair()136 pub fn action_pair() -> (CqFuture<bool>, CallTag) { in action_pair()139 (CqFuture::new(inner), CallTag::Action(action)) in action_pair()
23 use crate::task::{CallTag, CqFuture};528 cq_f: CqFuture<bool>,