Lines Matching refs:SomeData
49 async fn compress_output_unary(&self, _req: Request<()>) -> Result<Response<SomeData>, Status> { in compress_output_unary() argument
52 Ok(self.prepare_response(Response::new(SomeData { in compress_output_unary()
57 async fn compress_input_unary(&self, req: Request<SomeData>) -> Result<Response<()>, Status> { in compress_input_unary()
63 Pin<Box<dyn Stream<Item = Result<SomeData, Status>> + Send + 'static>>;
70 let stream = tokio_stream::iter(std::iter::repeat(SomeData { data })) in compress_output_server_stream()
78 req: Request<Streaming<SomeData>>, in compress_input_client_stream() argument
89 req: Request<Streaming<SomeData>>, in compress_output_client_stream() argument
90 ) -> Result<Response<SomeData>, Status> { in compress_output_client_stream() argument
98 Ok(self.prepare_response(Response::new(SomeData { in compress_output_client_stream()
104 Pin<Box<dyn Stream<Item = Result<SomeData, Status>> + Send + 'static>>;
108 req: Request<Streaming<SomeData>>, in compress_input_output_bidirectional_stream() argument
116 let stream = tokio_stream::iter(std::iter::repeat(SomeData { data })) in compress_input_output_bidirectional_stream()