Searched refs:FusedStream (Results 1 – 25 of 69) sorted by relevance
123
| /external/rust/crates/futures-core/src/ |
| D | stream.rs | 145 pub trait FusedStream: Stream { trait
150 impl<F: ?Sized + FusedStream + Unpin> FusedStream for &mut F { impl
152 <F as FusedStream>::is_terminated(&**self) in is_terminated()
156 impl<P> FusedStream for Pin<P>
159 P::Target: FusedStream,
162 <P::Target as FusedStream>::is_terminated(&**self) in is_terminated()
241 impl<S: ?Sized + FusedStream + Unpin> FusedStream for Box<S> {
243 <S as FusedStream>::is_terminated(&**self) in is_terminated()
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | select_next_some.rs | 3 use futures_core::stream::FusedStream;
22 impl<St: ?Sized + FusedStream + Unpin> FusedFuture for SelectNextSome<'_, St> {
28 impl<St: ?Sized + FusedStream + Unpin> Future for SelectNextSome<'_, St> {
|
| D | enumerate.rs | 3 use futures_core::stream::{FusedStream, Stream};
31 impl<St: Stream + FusedStream> FusedStream for Enumerate<St> {
|
| D | catch_unwind.rs | 1 use futures_core::stream::{Stream, FusedStream};
62 impl<St: FusedStream + UnwindSafe> FusedStream for CatchUnwind<St> {
|
| D | skip.rs | 3 use futures_core::stream::{FusedStream, Stream};
31 impl<St: FusedStream> FusedStream for Skip<St> {
|
| D | flatten.rs | 3 use futures_core::stream::{FusedStream, Stream};
29 impl<St> FusedStream for Flatten<St, St::Item>
31 St: FusedStream,
|
| D | take.rs | 4 use futures_core::stream::{Stream, FusedStream};
73 impl<St> FusedStream for Take<St>
74 where St: FusedStream,
|
| D | chain.rs | 3 use futures_core::stream::{FusedStream, Stream};
32 impl<St1, St2> FusedStream for Chain<St1, St2>
34 St2: FusedStream<Item=St1::Item>,
|
| D | map.rs | 4 use futures_core::stream::{FusedStream, Stream};
41 impl<St, F> FusedStream for Map<St, F>
42 where St: FusedStream,
|
| D | chunks.rs | 3 use futures_core::stream::{Stream, FusedStream};
91 impl<St: FusedStream> FusedStream for Chunks<St> {
|
| D | ready_chunks.rs | 2 use futures_core::stream::{Stream, FusedStream};
96 impl<St: FusedStream> FusedStream for ReadyChunks<St> {
|
| D | then.rs | 5 use futures_core::stream::{FusedStream, Stream};
51 impl<St, Fut, F> FusedStream for Then<St, Fut, F>
52 where St: FusedStream,
|
| D | next.rs | 4 use futures_core::stream::{FusedStream, Stream};
22 impl<St: ?Sized + FusedStream + Unpin> FusedFuture for Next<'_, St> {
|
| /external/rust/crates/futures-util/src/stream/try_stream/ |
| D | into_stream.rs | 2 use futures_core::stream::{FusedStream, Stream, TryStream};
27 impl<St: TryStream + FusedStream> FusedStream for IntoStream<St> {
|
| D | try_flatten.rs | 3 use futures_core::stream::{FusedStream, Stream, TryStream};
37 impl<St> FusedStream for TryFlatten<St>
39 St: TryStream + FusedStream,
|
| D | try_filter_map.rs | 5 use futures_core::stream::{Stream, TryStream, FusedStream};
45 impl<St, Fut, F, T> FusedStream for TryFilterMap<St, Fut, F>
46 where St: TryStream + FusedStream,
|
| D | and_then.rs | 5 use futures_core::stream::{Stream, TryStream, FusedStream};
86 impl<St, Fut, F> FusedStream for AndThen<St, Fut, F>
87 where St: TryStream + FusedStream,
|
| /external/rust/crates/futures-util/src/sink/ |
| D | err_into.rs | 2 use futures_core::stream::{Stream, FusedStream};
48 impl<S, Item, E> FusedStream for SinkErrInto<S, Item, E>
49 where S: Sink<Item> + FusedStream,
|
| D | map_err.rs | 2 use futures_core::stream::{Stream, FusedStream};
72 impl<S: FusedStream, F> FusedStream for SinkMapErr<S, F> {
|
| D | buffer.rs | 2 use futures_core::stream::{Stream, FusedStream};
63 impl<S, Item> FusedStream for Buffer<S, Item> where S: Sink<Item> + FusedStream {
|
| /external/rust/crates/futures-util/src/stream/ |
| D | repeat.rs | 3 use futures_core::stream::{Stream, FusedStream};
49 impl<T> FusedStream for Repeat<T>
|
| D | empty.rs | 4 use futures_core::stream::{FusedStream, Stream};
25 impl<T> FusedStream for Empty<T> {
|
| D | pending.rs | 4 use futures_core::stream::{FusedStream, Stream};
23 impl<T> FusedStream for Pending<T> {
|
| D | repeat_with.rs | 3 use futures_core::stream::{Stream, FusedStream};
31 impl<A, F: FnMut() -> A> FusedStream for RepeatWith<F>
|
| /external/rust/crates/futures-util/src/async_await/ |
| D | mod.rs | 7 use futures_core::stream::{Stream, FusedStream};
51 pub fn assert_fused_stream<T: Stream + FusedStream>(_: &T) {} in assert_fused_stream()
|
123