Lines Matching refs:resp_de
127 Ok(ClientUnaryReceiver::new(call, cq_f, method.resp_de())) in unary_async()
152 resp_de: method.resp_de(), in client_streaming()
186 Ok(ClientSStreamReceiver::new(call, cq_f, method.resp_de())) in server_streaming()
214 let recv = ClientDuplexReceiver::new(share_call, method.resp_de()); in duplex_streaming()
226 resp_de: DeserializeFn<T>, field
230 fn new(call: Call, resp_f: BatchFuture, resp_de: DeserializeFn<T>) -> ClientUnaryReceiver<T> { in new()
234 resp_de, in new()
245 pub fn resp_de(&self, reader: MessageReader) -> Result<T> { in resp_de() method
246 (self.resp_de)(reader) in resp_de()
255 let t = self.resp_de(data.unwrap())?; in poll()
270 resp_de: DeserializeFn<T>, field
282 pub fn resp_de(&self, reader: MessageReader) -> Result<T> { in resp_de() method
283 (self.resp_de)(reader) in resp_de()
305 let t = (self.resp_de)(data.unwrap())?; in poll()
429 resp_de: DeserializeFn<T>, field
433 fn new(call: H, resp_de: DeserializeFn<T>) -> ResponseStreamImpl<H, T> { in new()
439 resp_de, in new()
481 let msg = (self.resp_de)(data)?; in poll()