Searched refs:buffer_unordered (Results 1 – 3 of 3) sorted by relevance
174 mod buffer_unordered;177 pub use self::buffer_unordered::BufferUnordered;1192 fn buffer_unordered(self, n: usize) -> BufferUnordered<Self> in buffer_unordered() method
33 for item in block_on_stream(rx.buffer_unordered(N)) { in works()
239 let mut rx = rx.buffer_unordered(2); in unordered()257 let mut rx = rx.buffer_unordered(1); in unordered()