Lines Matching defs:Req
105 pub fn unary_async<Req, Resp>( in unary_async()
107 method: &Method<Req, Resp>, in unary_async()
108 req: &Req, in unary_async()
130 pub fn client_streaming<Req, Resp>( in client_streaming()
132 method: &Method<Req, Resp>, in client_streaming()
134 ) -> Result<(ClientCStreamSender<Req>, ClientCStreamReceiver<Resp>)> { in client_streaming()
158 pub fn server_streaming<Req, Resp>( in server_streaming()
160 method: &Method<Req, Resp>, in server_streaming()
161 req: &Req, in server_streaming()
189 pub fn duplex_streaming<Req, Resp>( in duplex_streaming()
191 method: &Method<Req, Resp>, in duplex_streaming()
193 ) -> Result<(ClientDuplexSender<Req>, ClientDuplexReceiver<Resp>)> { in duplex_streaming()
324 fn new(call: Arc<Mutex<ShareCall>>, req_ser: SerializeFn<Req>) -> StreamingCallSink<Req> { in new()
373 fn start_send(mut self: Pin<&mut Self>, (msg, flags): (Req, WriteFlags)) -> Result<()> { in start_send()