| /external/rust/crates/futures-util/src/stream/try_stream/ |
| D | try_flatten.rs | 3 use futures_core::stream::{FusedStream, Stream, TryStream};
15 St: TryStream,
26 St: TryStream,
27 St::Ok: TryStream,
28 <St::Ok as TryStream>::Error: From<St::Error>,
39 St: TryStream + FusedStream,
40 St::Ok: TryStream,
41 <St::Ok as TryStream>::Error: From<St::Error>,
50 St: TryStream,
51 St::Ok: TryStream,
[all …]
|
| D | try_filter.rs | 5 use futures_core::stream::{Stream, TryStream, FusedStream};
16 where St: TryStream
29 St: TryStream + fmt::Debug,
43 where St: TryStream
58 where St: TryStream + FusedStream,
68 where St: TryStream,
111 where S: TryStream + Sink<Item, Error = E>,
|
| D | try_take_while.rs | 5 use futures_core::stream::{FusedStream, Stream, TryStream};
17 St: TryStream,
31 St: TryStream + fmt::Debug,
47 St: TryStream,
66 St: TryStream,
117 St: TryStream + FusedStream,
130 S: TryStream + Sink<Item, Error = E>,
|
| D | try_skip_while.rs | 5 use futures_core::stream::{Stream, TryStream, FusedStream};
15 pub struct TrySkipWhile<St, Fut, F> where St: TryStream {
28 St: TryStream + fmt::Debug,
43 where St: TryStream,
61 where St: TryStream,
108 where St: TryStream + FusedStream,
120 where S: TryStream + Sink<Item, Error = E>,
|
| D | into_async_read.rs | 4 use futures_core::stream::TryStream;
16 St: TryStream<Error = Error> + Unpin,
25 St: TryStream<Error = Error> + Unpin,
39 St: TryStream<Error = Error> + Unpin,
52 St: TryStream<Error = Error> + Unpin,
107 St: TryStream<Error = Error> + AsyncWrite + Unpin,
135 St: TryStream<Error = Error> + Unpin,
|
| D | try_next.rs | 4 use futures_core::stream::{FusedStream, TryStream};
16 impl<'a, St: ?Sized + TryStream + Unpin> TryNext<'a, St> {
22 impl<St: ?Sized + TryStream + Unpin + FusedStream> FusedFuture for TryNext<'_, St> {
28 impl<St: ?Sized + TryStream + Unpin> Future for TryNext<'_, St> {
|
| D | try_buffered.rs | 4 use futures_core::stream::{Stream, TryStream};
17 St: TryStream,
29 St: TryStream,
45 St: TryStream,
84 S: TryStream + Sink<Item, Error = E>,
|
| D | try_buffer_unordered.rs | 4 use futures_core::stream::{Stream, TryStream};
17 where St: TryStream
27 where St: TryStream,
42 where St: TryStream,
80 where S: TryStream + Sink<Item, Error = E>,
|
| D | try_concat.rs | 4 use futures_core::stream::TryStream;
12 pub struct TryConcat<St: TryStream> {
21 St: TryStream,
34 St: TryStream,
|
| D | try_collect.rs | 5 use futures_core::stream::{FusedStream, TryStream};
20 impl<St: TryStream, C: Default> TryCollect<St, C> {
31 St: TryStream + FusedStream,
41 St: TryStream,
|
| D | into_stream.rs | 2 use futures_core::stream::{FusedStream, Stream, TryStream};
27 impl<St: TryStream + FusedStream> FusedStream for IntoStream<St> {
33 impl<St: TryStream> Stream for IntoStream<St> {
|
| D | and_then.rs | 5 use futures_core::stream::{Stream, TryStream, FusedStream};
37 where St: TryStream,
49 where St: TryStream,
87 where St: TryStream + FusedStream,
|
| D | try_fold.rs | 5 use futures_core::stream::TryStream;
38 where St: TryStream,
53 where St: TryStream,
63 where St: TryStream,
|
| D | or_else.rs | 5 use futures_core::stream::{Stream, TryStream, FusedStream};
37 where St: TryStream,
49 where St: TryStream,
91 where St: TryStream + FusedStream,
|
| D | mod.rs | 11 stream::TryStream,
141 impl<S: ?Sized + TryStream> TryStreamExt for S {}
144 pub trait TryStreamExt: TryStream {
694 Self::Ok: TryStream, in try_flatten() argument
695 <Self::Ok as TryStream>::Error: From<Self::Error>, in try_flatten()
698 assert_stream::<Result<<Self::Ok as TryStream>::Ok, <Self::Ok as TryStream>::Error>, _>( in try_flatten()
777 Self::Ok: Extend<<<Self as TryStream>::Ok as IntoIterator>::Item> + IntoIterator + Default, in try_concat()
|
| D | try_for_each.rs | 5 use futures_core::stream::TryStream;
35 where St: TryStream,
49 where St: TryStream,
|
| D | try_for_each_concurrent.rs | 7 use futures_core::stream::TryStream;
40 where St: TryStream,
50 where St: TryStream,
66 where St: TryStream,
|
| D | try_filter_map.rs | 5 use futures_core::stream::{Stream, TryStream, FusedStream};
46 where St: TryStream + FusedStream,
56 where St: TryStream,
|
| /external/rust/crates/futures-util/src/sink/ |
| D | send_all.rs | 6 use futures_core::stream::{TryStream, Stream};
16 St: ?Sized + TryStream,
26 St: fmt::Debug + ?Sized + TryStream,
42 St: TryStream + Unpin + ?Sized,
48 St: TryStream<Ok = Ok, Error = Error> + Stream + Unpin + ?Sized,
|
| D | mod.rs | 12 use futures_core::stream::{Stream, TryStream};
253 St: TryStream<Ok = Item, Error = Self::Error> + Stream + Unpin + ?Sized, in send_all()
|
| /external/rust/crates/futures-util/src/future/try_future/ |
| D | try_flatten.rs | 4 use futures_core::stream::{FusedStream, Stream, TryStream};
69 Fut::Ok: TryStream<Error=Fut::Error>,
81 Fut::Ok: TryStream<Error=Fut::Error>,
83 type Item = Result<<Fut::Ok as TryStream>::Ok, Fut::Error>;
|
| D | mod.rs | 11 stream::TryStream,
534 Self::Ok: TryStream<Error = Self::Error>, in try_flatten_stream()
537 assert_stream::<Result<<Self::Ok as TryStream>::Ok, Self::Error>, _>(TryFlattenStream::new( in try_flatten_stream()
|
| /external/rust/crates/futures/tests/ |
| D | object_safety.rs | 16 use futures::stream::{FusedStream, Stream, TryStream}; in stream()
20 assert_is_object_safe::<&dyn TryStream<Ok = (), Error = (), Item = Result<(), ()>>>(); in stream()
|
| /external/rust/crates/futures/src/ |
| D | lib.rs | 109 pub use futures_core::stream::{Stream, TryStream};
175 pub use crate::stream::{self, Stream, TryStream};
|
| /external/rust/crates/futures-core/src/ |
| D | stream.rs | 176 pub trait TryStream: Stream + private_try_stream::Sealed { interface
192 impl<S, T, E> TryStream for S
|