14
14
* with global limits
15
15
* and with an optional group specified for each future, with its own limits.
16
16
17
- This crate is part of the [ nextest organization] ( https://github.com/nextest-rs ) on GitHub, and is
18
- designed to serve the needs of [ cargo-nextest] ( https://nexte.st ) .
17
+ This crate is part of the [ nextest organization] ( https://github.com/nextest-rs ) on GitHub, and
18
+ is designed to serve the needs of [ cargo-nextest] ( https://nexte.st ) .
19
19
20
20
## Motivation
21
21
@@ -25,8 +25,8 @@ this adaptor takes a stream of futures[^1], and executes all the futures limited
25
25
amount of concurrency.
26
26
27
27
* Futures are started in the order the stream returns them in.
28
- * Once started, futures are polled simultaneously, and completed future outputs are returned
29
- in arbitrary order (hence the ` unordered ` ).
28
+ * Once started, futures are polled simultaneously, and completed future outputs are returned in
29
+ arbitrary order (hence the ` unordered ` ).
30
30
31
31
Common use cases for ` buffer_unordered ` include:
32
32
@@ -99,10 +99,10 @@ except it is possible to specify an optional *group* for each future. Each group
99
99
weight, and a future will only be scheduled if both the maximum weight and the group weight
100
100
aren't exceeded.
101
101
102
- The adaptor is as fair as possible under the given constraints: it will schedule futures in
103
- the order they're returned by the stream, without doing any reordering based on weight. When
104
- a future from a group completes, queued up futures in this group will be preferentially
105
- scheduled before any other futures from the provided stream.
102
+ The adaptor is as fair as possible under the given constraints: it will schedule futures in the
103
+ order they're returned by the stream, without doing any reordering based on weight. When a
104
+ future from a group completes, queued up futures in this group will be preferentially scheduled
105
+ before any other futures from the provided stream.
106
106
107
107
Like with [ ` future_queue ` ] ( StreamExt::future_queue ) :
108
108
@@ -140,11 +140,11 @@ assert_eq!(queue.next().await, None);
140
140
141
141
## Minimum supported Rust version (MSRV)
142
142
143
- The minimum supported Rust version is ** Rust 1.56.**
143
+ The minimum supported Rust version is ** Rust 1.70.** At any time, at least the last six months
144
+ of Rust stable releases are supported.
144
145
145
- The MSRV will likely not change in the medium term, but while this crate is a pre-release
146
- (0.x.x) it may have its MSRV bumped in a patch release. Once this crate has reached 1.x, any
147
- MSRV bump will be accompanied with a new minor version.
146
+ While this crate is a pre-release (0.x.x) it may have its MSRV bumped in a patch release. Once
147
+ this crate has reached 1.x, any MSRV bump will be accompanied with a new minor version.
148
148
149
149
## Notes
150
150
0 commit comments