Searched refs:BatchFuture (Results 1 – 4 of 4) sorted by relevance
| /external/rust/crates/grpcio/src/call/ |
| D | mod.rs | 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>,
[all …]
|
| D | client.rs | 23 use crate::task::{BatchFuture, BatchType};
225 resp_f: BatchFuture,
230 fn new(call: Call, resp_f: BatchFuture, resp_de: DeserializeFn<T>) -> ClientUnaryReceiver<T> { in new() argument
319 close_f: Option<BatchFuture>,
426 msg_f: Option<BatchFuture>,
505 finish_f: BatchFuture, in new() argument
|
| D | server.rs | 31 use crate::task::{BatchFuture, CallTag, Executor, Kicker};
314 cq_f: Option<BatchFuture>,
430 flush_f: Option<BatchFuture>,
558 fail_f: Option<BatchFuture>,
|
| /external/rust/crates/grpcio/src/task/ |
| D | mod.rs | 107 pub type BatchFuture = CqFuture<Option<MessageReader>>; typedef
122 pub fn batch_pair(ty: BatchType) -> (BatchFuture, CallTag) { in batch_pair() argument
|