Searched refs:IntoStream (Results 1 – 8 of 8) sorted by relevance
| /external/rust/crates/futures-util/src/stream/try_stream/ |
| D | into_stream.rs | 12 pub struct IntoStream<St> {
18 impl<St> IntoStream<St> { impl
27 impl<St: TryStream + FusedStream> FusedStream for IntoStream<St> { implementation
33 impl<St: TryStream> Stream for IntoStream<St> { implementation
51 impl<S: Sink<Item>, Item> Sink<Item> for IntoStream<S> { implementation
|
| D | mod.rs | 35 Inspect<IntoStream<St>, InspectOkFn<F>>
36 … FusedStream + AccessInner[St, (. .)] + New[|x: St, f: F| Inspect::new(IntoStream::new(x), inspect…
42 Inspect<IntoStream<St>, InspectErrFn<F>>
43 … FusedStream + AccessInner[St, (. .)] + New[|x: St, f: F| Inspect::new(IntoStream::new(x), inspect…
48 pub use self::into_stream::IntoStream;
53 Map<IntoStream<St>, MapOkFn<F>>
54 …am + FusedStream + AccessInner[St, (. .)] + New[|x: St, f: F| Map::new(IntoStream::new(x), map_ok_…
60 Map<IntoStream<St>, MapErrFn<F>>
61 …am + FusedStream + AccessInner[St, (. .)] + New[|x: St, f: F| Map::new(IntoStream::new(x), map_err…
341 fn into_stream(self) -> IntoStream<Self> in into_stream()
[all …]
|
| D | try_buffer_unordered.rs | 1 use crate::stream::{Fuse, FuturesUnordered, StreamExt, IntoStream};
20 stream: Fuse<IntoStream<St>>,
32 stream: IntoStream::new(stream).fuse(), in new()
|
| D | try_buffered.rs | 1 use crate::stream::{Fuse, FuturesOrdered, StreamExt, IntoStream};
21 stream: Fuse<IntoStream<St>>,
34 stream: IntoStream::new(stream).fuse(), in new()
|
| /external/rust/crates/futures-util/src/future/future/ |
| D | mod.rs | 57 IntoStream<F>(
278 fn into_stream(self) -> IntoStream<Self> in into_stream()
282 assert_stream::<Self::Output, _>(IntoStream::new(self)) in into_stream()
|
| /external/rust/crates/futures-util/src/future/ |
| D | mod.rs | 24 Flatten, Fuse, FutureExt, Inspect, IntoStream, Map, NeverError, Then, UnitError, MapInto,
|
| /external/rust/crates/futures-util/src/stream/ |
| D | mod.rs | 51 try_unfold, AndThen, ErrInto, InspectErr, InspectOk, IntoStream, MapErr, MapOk, OrElse,
|
| /external/rust/crates/futures/tests/ |
| D | auto_traits.rs | 342 assert_impl!(IntoStream<SendFuture>: Send);
343 assert_not_impl!(IntoStream<LocalFuture>: Send);
344 assert_impl!(IntoStream<SyncFuture>: Sync);
345 assert_not_impl!(IntoStream<LocalFuture>: Sync);
346 assert_impl!(IntoStream<UnpinFuture>: Unpin);
347 assert_not_impl!(IntoStream<PinnedFuture>: Unpin);
1339 assert_impl!(IntoStream<()>: Send);
1340 assert_not_impl!(IntoStream<*const ()>: Send);
1341 assert_impl!(IntoStream<()>: Sync);
1342 assert_not_impl!(IntoStream<*const ()>: Sync);
[all …]
|