Searched refs:flatten_unordered (Results 1 – 12 of 12) sorted by relevance
63 fn flatten_unordered() { in flatten_unordered() function149 let fl_unordered = st.flatten_unordered(3).collect::<Vec<_>>().await; in flatten_unordered()178 .flatten_unordered(10) in flatten_unordered()206 .flatten_unordered(10) in flatten_unordered()236 .flatten_unordered(10) in flatten_unordered()302 let stream = Arc::new(Mutex::new(st.flatten_unordered(10))); in flatten_unordered()368 .flatten_unordered(None); in flatten_unordered()370 stream::once(future::ready(inner)).flatten_unordered(None) in flatten_unordered()
46 name = "flatten_unordered"47 path = "benches/flatten_unordered.rs"
202 pub(crate) mod flatten_unordered; module207 pub use self::flatten_unordered::FlattenUnordered;825 fn flatten_unordered(self, limit: impl Into<Option<usize>>) -> FlattenUnordered<Self> in flatten_unordered() method
40 .flatten_unordered(None); in oneshot_streams()
13 use crate::stream::stream::flatten_unordered::{
1 …ternal/rust/android-crates-io/crates/futures-util/src/stream/stream/flatten_unordered.rs external/…3 …ternal/rust/android-crates-io/crates/futures-util/src/stream/stream/flatten_unordered.rs external/…79 external/rust/android-crates-io/crates/futures-util/src/stream/stream/flatten_unordered.rs:
1 …ternal/rust/android-crates-io/crates/futures-util/src/stream/stream/flatten_unordered.rs external/…
2551 "name": "flatten_unordered",2552 …go/registry/src/index.crates.io-6f17d22bba15001f/futures-util-0.3.30/benches/flatten_unordered.rs",