Lines Matching refs:BatchFuture
23 use crate::task::{self, BatchFuture, BatchType, CallTag};
259 fn check_run<F>(bt: BatchType, f: F) -> BatchFuture in check_run()
299 ) -> Result<BatchFuture> { in start_send_message() argument
316 pub fn start_send_close_client(&mut self) -> Result<BatchFuture> { in start_send_close_client() argument
325 pub fn start_recv_message(&mut self) -> Result<BatchFuture> { in start_recv_message() argument
336 pub fn start_server_side(&mut self) -> Result<BatchFuture> { in start_server_side() argument
351 ) -> Result<BatchFuture> { in start_send_status_from_server() argument
446 close_f: BatchFuture,
452 fn new(call: Call, close_f: BatchFuture) -> ShareCall { in new()
513 close_f: Option<BatchFuture>,
514 msg_f: Option<BatchFuture>,
519 fn new(close_f: Option<BatchFuture>) -> StreamingBase { in new()
627 batch_f: Option<BatchFuture>,