Searched refs:ClientDuplexReceiver (Results 1 – 3 of 3) sorted by relevance
| /external/rust/crates/grpcio/src/call/ |
| D | client.rs | 193 ) -> Result<(ClientDuplexSender<Req>, ClientDuplexReceiver<Resp>)> { in duplex_streaming()
214 let recv = ClientDuplexReceiver::new(share_call, method.resp_de()); in duplex_streaming()
536 pub struct ClientDuplexReceiver<Resp> { struct
540 impl<Resp> ClientDuplexReceiver<Resp> { argument
541 fn new(call: Arc<Mutex<ShareCall>>, de: DeserializeFn<Resp>) -> ClientDuplexReceiver<Resp> { in new()
542 ClientDuplexReceiver { in new()
552 impl<Resp> Drop for ClientDuplexReceiver<Resp> { implementation
560 impl<Resp> Stream for ClientDuplexReceiver<Resp> { implementation
|
| /external/rust/crates/grpcio/src/ |
| D | client.rs | 4 CallOption, ClientCStreamReceiver, ClientCStreamSender, ClientDuplexReceiver,
85 ) -> Result<(ClientDuplexSender<Req>, ClientDuplexReceiver<Resp>)> { in duplex_streaming()
|
| D | lib.rs | 48 CallOption, ClientCStreamReceiver, ClientCStreamSender, ClientDuplexReceiver,
|