Searched refs:share_call (Results 1 – 1 of 1) sorted by relevance
148 let share_call = Arc::new(Mutex::new(ShareCall::new(call, cq_f))); in client_streaming() localVariable149 let sink = ClientCStreamSender::new(share_call.clone(), method.req_ser()); in client_streaming()151 call: share_call, in client_streaming()212 let share_call = Arc::new(Mutex::new(ShareCall::new(call, cq_f))); in duplex_streaming() localVariable213 let sink = ClientDuplexSender::new(share_call.clone(), method.req_ser()); in duplex_streaming()214 let recv = ClientDuplexReceiver::new(share_call, method.resp_de()); in duplex_streaming()508 let share_call = ShareCall::new(call, finish_f); in new() localVariable510 imp: ResponseStreamImpl::new(share_call, de), in new()