Lines Matching refs:req
32 let req = request.into_inner(); in unary_call() localVariable
34 if let Some(echo_status) = req.response_status { in unary_call()
39 let res_size = if req.response_size >= 0 { in unary_call()
40 req.response_size as usize in unary_call()
65 req: Request<StreamingOutputCallRequest>, in streaming_output_call()
70 } = req.into_inner(); in streaming_output_call()
88 req: Streaming<StreamingInputCallRequest>, in streaming_input_call()
90 let mut stream = req.into_inner(); in streaming_input_call()
108 req: Streaming<StreamingOutputCallRequest>, in full_duplex_call()
110 let mut stream = req.into_inner(); in full_duplex_call()
196 fn call(&mut self, req: http::Request<Body>) -> Self::Future { in call()
197 let echo_header = req.headers().get("x-grpc-test-echo-initial").cloned(); in call()
200 let echo_trailer = req in call()
206 let call = self.inner.call(req); in call()