Lines Matching refs:ShareCall
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()
776 let call = Arc::new(Mutex::new(ShareCall::new(call, close_f))); in execute_duplex_streaming()