Searched refs:BatchType (Results 1 – 4 of 4) sorted by relevance
| /external/rust/crates/grpcio/src/task/ |
| D | promise.rs | 12 pub enum BatchType { enum
23 ty: BatchType,
29 pub fn new(ty: BatchType, inner: Arc<Inner<Option<MessageReader>>>) -> Batch { in new() argument
87 BatchType::CheckRead => { in resolve()
91 BatchType::Finish => { in resolve()
94 BatchType::Read => { in resolve()
|
| D | mod.rs | 25 pub use self::promise::BatchType;
122 pub fn batch_pair(ty: BatchType) -> (BatchFuture, CallTag) { in batch_pair()
|
| /external/rust/crates/grpcio/src/call/ |
| D | client.rs | 23 use crate::task::{BatchFuture, BatchType};
114 let cq_f = check_run(BatchType::CheckRead, |ctx, tag| unsafe { in unary_async()
136 let cq_f = check_run(BatchType::CheckRead, |ctx, tag| unsafe { in client_streaming()
167 let cq_f = check_run(BatchType::Finish, |ctx, tag| unsafe { in server_streaming()
182 check_run(BatchType::Finish, |ctx, tag| unsafe { in server_streaming()
195 let cq_f = check_run(BatchType::Finish, |ctx, tag| unsafe { in duplex_streaming()
208 check_run(BatchType::Finish, |ctx, tag| unsafe { in duplex_streaming()
|
| D | mod.rs | 23 use crate::task::{self, BatchFuture, BatchType, CallTag};
259 fn check_run<F>(bt: BatchType, f: F) -> BatchFuture in check_run() argument
302 let f = check_run(BatchType::Finish, |ctx, tag| unsafe { in start_send_message()
318 let f = check_run(BatchType::Finish, |_, tag| unsafe { in start_send_close_client()
327 let f = check_run(BatchType::Read, |ctx, tag| unsafe { in start_recv_message()
338 let f = check_run(BatchType::Finish, |ctx, tag| unsafe { in start_server_side()
354 let f = check_run(BatchType::Finish, |ctx, tag| unsafe { in start_send_status_from_server()
|