Home
last modified time | relevance | path

Searched refs:Stream (Results 1 – 25 of 39) sorted by relevance

12

/tonic/tests/integration_tests/tests/
H A Dstreams.rs5 type Stream<T> = std::pin::Pin< typedef
6 Box<dyn tokio_stream::Stream<Item = std::result::Result<T, Status>> + Send + 'static>,
15 type StreamCallStream = Stream<OutputStream>; in status_from_server_stream_with_source()
49 impl tokio_stream::Stream for Unsync {
H A Dstatus.rs138 type Stream<T> = std::pin::Pin< typedef
139 Box<dyn tokio_stream::Stream<Item = std::result::Result<T, Status>> + Send + 'static>,
150 type StreamCallStream = Stream<OutputStream>; in status_from_server_stream()
220 type StreamCallStream = Stream<OutputStream>; in message_and_then_status_from_server_stream()
H A Dmax_message_size.rs8 use tokio_stream::Stream;
132 Pin<Box<dyn Stream<Item = Result<Output1, Status>> + Send + 'static>>; in response_stream_limit()
291 Pin<Box<dyn Stream<Item = Result<Output1, Status>> + Send + 'static>>; in max_message_run()
/tonic/tests/default_stubs/src/
H A Dlib.rs6 use tokio_stream::{Stream, StreamExt};
17 type ServerStreamStream = Pin<Box<dyn Stream<Item = Result<(), Status>> + Send + 'static>>;
19 Pin<Box<dyn Stream<Item = Result<(), Status>> + Send + 'static>>;
/tonic/tonic/src/server/
H A Dservice.rs3 use tokio_stream::Stream;
42 type ResponseStream: Stream<Item = Result<Self::Response, Status>>;
54 S: Stream<Item = Result<M2, crate::Status>>,
101 type ResponseStream: Stream<Item = Result<Self::Response, Status>>;
113 S: Stream<Item = Result<M2, crate::Status>>,
/tonic/tonic/src/
H A Drequest.rs14 use tokio_stream::Stream;
92 type Stream: Stream<Item = Self::Message> + Send + 'static; typedef
98 fn into_streaming_request(self) -> Request<Self::Stream>; in into_streaming_request() argument
369 T: Stream + Send + 'static,
371 type Stream = T; typedef
381 T: Stream + Send + 'static,
383 type Stream = T; typedef
H A Dcodegen.rs21 self::Pin<Box<dyn tokio_stream::Stream<Item = Result<T, crate::Status>> + Send + 'static>>;
/tonic/tonic/src/transport/server/
H A Dio_stream.rs14 use tokio_stream::Stream;
28 S: Stream<Item = Result<IO, IE>>,
38 S: Stream<Item = Result<IO, IE>>,
69 impl<S, IO, IE> Stream for ServerIoStream<S, IO, IE>
71 S: Stream<Item = Result<IO, IE>>,
146 incoming: &mut (impl Stream<Item = Result<IO, IE>> + Unpin), in select()
H A Dincoming.rs10 use tokio_stream::{wrappers::TcpListenerStream, Stream};
85 impl Stream for TcpIncoming {
/tonic/tonic/src/codec/
H A Dencode.rs14 use tokio_stream::{adapters::Fuse, Stream, StreamExt};
34 impl<T: Encoder, U: Stream> EncodedBytes<T, U> {
70 impl<T, U> Stream for EncodedBytes<T, U>
73 U: Stream<Item = Result<T::Item, Status>>,
231 impl<T: Encoder, U: Stream> EncodeBody<T, U> {
306 U: Stream<Item = Result<T::Item, Status>>,
/tonic/tonic/src/transport/channel/service/
H A Ddiscover.rs9 use tokio_stream::Stream;
31 impl<K: Hash + Eq + Clone> Stream for DynamicServiceStream<K> {
/tonic/tests/stream_conflict/proto/
H A Dstream_conflict.proto8 service Stream { service
/tonic/interop/src/
H A Dserver.rs22 type Stream<T> = Pin<Box<dyn tokio_stream::Stream<Item = StdResult<T, Status>> + Send + 'static>>; typedef
61 type StreamingOutputCallStream = Stream<StreamingOutputCallResponse>;
104 type FullDuplexCallStream = Stream<StreamingOutputCallResponse>;
144 type HalfDuplexCallStream = Stream<StreamingOutputCallResponse>;
/tonic/tests/compression/src/
H A Dlib.rs13 use tokio_stream::{Stream, StreamExt};
63 Pin<Box<dyn Stream<Item = Result<SomeData, Status>> + Send + 'static>>;
104 Pin<Box<dyn Stream<Item = Result<SomeData, Status>> + Send + 'static>>;
/tonic/examples/src/streaming/
H A Dclient.rs6 use tokio_stream::{Stream, StreamExt};
11 fn echo_requests_iter() -> impl Stream<Item = EchoRequest> { in echo_requests_iter()
H A Dserver.rs7 use tokio_stream::{wrappers::ReceiverStream, Stream, StreamExt};
13 type ResponseStream = Pin<Box<dyn Stream<Item = Result<EchoResponse, Status>> + Send>>;
/tonic/tests/web/src/
H A Dlib.rs3 use tokio_stream::{self as stream, Stream, StreamExt};
12 type BoxStream<T> = Pin<Box<dyn Stream<Item = Result<T, Status>> + Send + 'static>>;
/tonic/tests/use_arc_self/src/
H A Dlib.rs4 use tokio_stream::{Stream, StreamExt};
/tonic/tonic-reflection/src/server/
H A Dv1alpha.rs4 use tokio_stream::{Stream, StreamExt};
119 impl Stream for ServerReflectionInfoStream {
H A Dv1.rs4 use tokio_stream::{Stream, StreamExt};
119 impl Stream for ServerReflectionInfoStream {
/tonic/tonic-web/
H A DCargo.toml47 "futures_core::stream::Stream",
/tonic/tonic-health/
H A DCargo.toml43 "futures_core::stream::Stream",
/tonic/tonic/src/client/
H A Dgrpc.rs17 use tokio_stream::{Stream, StreamExt};
236 S: Stream<Item = M1> + Send + 'static, in client_streaming()
292 S: Stream<Item = M1> + Send + 'static, in streaming()
/tonic/tonic-reflection/
H A DCargo.toml56 "futures_core::stream::Stream",
/tonic/examples/src/routeguide/
H A Dserver.rs7 use tokio_stream::{wrappers::ReceiverStream, Stream, StreamExt};
104 type RouteChatStream = Pin<Box<dyn Stream<Item = Result<RouteNote, Status>> + Send + 'static>>;

12