Searched refs:ResponseStream (Results 1 – 7 of 7) sorted by relevance
| /tonic/tonic/src/server/ |
| H A D | service.rs | 42 type ResponseStream: Stream<Item = Result<Self::Response, Status>>; typedef
45 type Future: Future<Output = Result<Response<Self::ResponseStream>, Status>>;
57 type ResponseStream = S; typedef
101 type ResponseStream: Stream<Item = Result<Self::Response, Status>>; typedef
104 type Future: Future<Output = Result<Response<Self::ResponseStream>, Status>>;
116 type ResponseStream = S; typedef
|
| H A D | grpc.rs | 269 S::ResponseStream: Send + 'static, in server_streaming()
281 return self.map_response::<S::ResponseStream>( in server_streaming()
343 S::ResponseStream: Send + 'static, in streaming()
|
| /tonic/examples/src/streaming/ |
| H A D | server.rs | 13 type ResponseStream = Pin<Box<dyn Stream<Item = Result<EchoResponse, Status>> + Send>>; typedef
44 type ServerStreamingEchoStream = ResponseStream;
90 type BidirectionalStreamingEchoStream = ResponseStream;
|
| /tonic/tonic-build/src/ |
| H A D | server.rs | 510 quote!(type ResponseStream = T::#stream) in generate_server_streaming()
512 quote!(type ResponseStream = BoxStream<#response>) in generate_server_streaming()
528 type Future = BoxFuture<tonic::Response<Self::ResponseStream>, tonic::Status>; in generate_server_streaming()
635 quote!(type ResponseStream = T::#stream) in generate_streaming()
637 quote!(type ResponseStream = BoxStream<#response>) in generate_streaming()
654 type Future = BoxFuture<tonic::Response<Self::ResponseStream>, tonic::Status>; in generate_streaming()
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 382 type ResponseStream = T::WatchStream; in call() typedef
384 tonic::Response<Self::ResponseStream>, in call()
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 378 type ResponseStream = T::ServerReflectionInfoStream; in call() typedef
380 tonic::Response<Self::ResponseStream>, in call()
|
| H A D | grpc_reflection_v1alpha.rs | 378 type ResponseStream = T::ServerReflectionInfoStream; in call() typedef
380 tonic::Response<Self::ResponseStream>, in call()
|