Home
last modified time | relevance | path

Searched refs:StreamCallStream (Results 1 – 4 of 4) sorted by relevance

/tonic/tests/integration_tests/tests/
H A Dstreams.rs15 type StreamCallStream = Stream<OutputStream>; in status_from_server_stream_with_source() typedef
20 ) -> Result<Response<Self::StreamCallStream>, Status> { in status_from_server_stream_with_source() argument
23 Ok(Response::new(Box::pin(s) as Self::StreamCallStream)) in status_from_server_stream_with_source()
H A Dstatus.rs150 type StreamCallStream = Stream<OutputStream>; in status_from_server_stream() typedef
155 ) -> Result<Response<Self::StreamCallStream>, Status> { in status_from_server_stream() argument
160 Ok(Response::new(Box::pin(s) as Self::StreamCallStream)) in status_from_server_stream()
220 type StreamCallStream = Stream<OutputStream>; in message_and_then_status_from_server_stream() typedef
225 ) -> Result<Response<Self::StreamCallStream>, Status> { in message_and_then_status_from_server_stream() argument
230 Ok(Response::new(Box::pin(s) as Self::StreamCallStream)) in message_and_then_status_from_server_stream()
H A Dmax_message_size.rs131 type StreamCallStream = in response_stream_limit() typedef
137 ) -> Result<Response<Self::StreamCallStream>, Status> { in response_stream_limit() argument
290 type StreamCallStream = in max_message_run() typedef
296 ) -> Result<Response<Self::StreamCallStream>, Status> { in max_message_run() argument
H A Droutes_builder.rs38 type StreamCallStream = BoxStream<Output1>; in multiple_service_using_routes_builder() typedef
43 ) -> Result<Response<Self::StreamCallStream>, Status> { in multiple_service_using_routes_builder() argument