Lines Matching refs:Resp
105 pub fn unary_async<Req, Resp>( in unary_async() argument
107 method: &Method<Req, Resp>, in unary_async()
110 ) -> Result<ClientUnaryReceiver<Resp>> { in unary_async() argument
130 pub fn client_streaming<Req, Resp>( in client_streaming() argument
132 method: &Method<Req, Resp>, in client_streaming()
134 ) -> Result<(ClientCStreamSender<Req>, ClientCStreamReceiver<Resp>)> { in client_streaming() argument
158 pub fn server_streaming<Req, Resp>( in server_streaming() argument
160 method: &Method<Req, Resp>, in server_streaming()
163 ) -> Result<ClientSStreamReceiver<Resp>> { in server_streaming() argument
189 pub fn duplex_streaming<Req, Resp>( in duplex_streaming() argument
191 method: &Method<Req, Resp>, in duplex_streaming()
193 ) -> Result<(ClientDuplexSender<Req>, ClientDuplexReceiver<Resp>)> { in duplex_streaming() argument
498 pub struct ClientSStreamReceiver<Resp> {
499 imp: ResponseStreamImpl<ShareCall, Resp>,
502 impl<Resp> ClientSStreamReceiver<Resp> {
506 de: DeserializeFn<Resp>, in new() argument
507 ) -> ClientSStreamReceiver<Resp> { in new() argument
519 impl<Resp> Stream for ClientSStreamReceiver<Resp> {
520 type Item = Result<Resp>;
536 pub struct ClientDuplexReceiver<Resp> {
537 imp: ResponseStreamImpl<Arc<Mutex<ShareCall>>, Resp>,
540 impl<Resp> ClientDuplexReceiver<Resp> {
541 fn new(call: Arc<Mutex<ShareCall>>, de: DeserializeFn<Resp>) -> ClientDuplexReceiver<Resp> { in new() argument
552 impl<Resp> Drop for ClientDuplexReceiver<Resp> {
560 impl<Resp> Stream for ClientDuplexReceiver<Resp> {
561 type Item = Result<Resp>;