Searched refs:ShareCall (Results 1 – 3 of 3) sorted by relevance
| /external/rust/crates/grpcio/src/call/ |
| D | client.rs | 16 use super::{ShareCall, ShareCallHolder, SinkBase, WriteFlags};
148 let share_call = Arc::new(Mutex::new(ShareCall::new(call, cq_f))); in client_streaming()
212 let share_call = Arc::new(Mutex::new(ShareCall::new(call, cq_f))); in duplex_streaming()
269 call: Arc<Mutex<ShareCall>>,
317 call: Arc<Mutex<ShareCall>>,
324 fn new(call: Arc<Mutex<ShareCall>>, req_ser: SerializeFn<Req>) -> StreamingCallSink<Req> { in new() argument
499 imp: ResponseStreamImpl<ShareCall, Resp>,
508 let share_call = ShareCall::new(call, finish_f); in new()
537 imp: ResponseStreamImpl<Arc<Mutex<ShareCall>>, Resp>,
541 fn new(call: Arc<Mutex<ShareCall>>, de: DeserializeFn<Resp>) -> ClientDuplexReceiver<Resp> { in new() argument
|
| D | server.rs | 19 use super::{RpcStatus, ShareCall, ShareCallHolder, WriteFlags};
266 call: Arc<Mutex<ShareCall>>,
272 fn new(call: Arc<Mutex<ShareCall>>, de: DeserializeFn<T>) -> RequestStream<T> { in new() argument
408 ShareCall
420 Arc<Mutex<ShareCall>>
599 ShareCall
611 Arc<Mutex<ShareCall>>
714 let sink = UnarySink::new(ShareCall::new(call, close_f), ser); in execute_unary()
729 let call = Arc::new(Mutex::new(ShareCall::new(call, close_f))); in execute_client_streaming()
761 let sink = ServerStreamingSink::new(ShareCall::new(call, close_f), ser); in execute_server_streaming()
[all …]
|
| D | mod.rs | 444 struct ShareCall { struct
451 impl ShareCall { argument
452 fn new(call: Call, close_f: BatchFuture) -> ShareCall { in new() argument
453 ShareCall { in new()
495 fn call<R, F: FnOnce(&mut ShareCall) -> R>(&mut self, f: F) -> R; in call()
498 impl ShareCallHolder for ShareCall { implementation
499 fn call<R, F: FnOnce(&mut ShareCall) -> R>(&mut self, f: F) -> R { in call()
504 impl ShareCallHolder for Arc<Mutex<ShareCall>> {
505 fn call<R, F: FnOnce(&mut ShareCall) -> R>(&mut self, f: F) -> R { in call()
|