Searched refs:buffer_unordered (Results 1 – 9 of 9) sorted by relevance
186 mod buffer_unordered; module190 pub use self::buffer_unordered::BufferUnordered;1415 fn buffer_unordered(self, n: usize) -> BufferUnordered<Self> in buffer_unordered() method
220 let mut rx = rx.buffer_unordered(2); in unordered()238 let mut rx = rx.buffer_unordered(1); in unordered()
33 for item in block_on_stream(rx.buffer_unordered(N)) { in works()
1 …ternal/rust/android-crates-io/crates/futures-util/src/stream/stream/buffer_unordered.rs external/r…3 …ternal/rust/android-crates-io/crates/futures-util/src/stream/stream/buffer_unordered.rs external/r…77 external/rust/android-crates-io/crates/futures-util/src/stream/stream/buffer_unordered.rs:
1 …ternal/rust/android-crates-io/crates/futures-util/src/stream/stream/buffer_unordered.rs external/r…