Searched refs:resp_de (Results 1 – 2 of 2) sorted by relevance
| /external/rust/crates/grpcio/src/call/ |
| D | client.rs | 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()
[all …]
|
| D | mod.rs | 150 pub fn resp_de(&self) -> DeserializeFn<Resp> { in resp_de() method
|