Skip to content

Commit 058603d

Browse files
committed
Allow deprecated Atomic::fetch_update
fetch_update was renamed to try_update in rust 1.95.0, and the old name (probably) gets deprecated in 1.99.0; MSRV is 1.71.
1 parent edccd29 commit 058603d

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

futures-util/src/stream/stream/flatten_unordered.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,7 @@ impl SharedPollState {
6363
/// Attempts to start polling, returning stored state in case of success.
6464
/// Returns `None` if either waker is waking at the moment.
6565
fn start_polling(&self) -> Option<(u8, PollStateBomb<'_, impl FnOnce(&Self) -> u8>)> {
66+
#[allow(deprecated)] // fetch_update was renamed to try_update in rust 1.95.0
6667
let value = self
6768
.state
6869
.fetch_update(Ordering::SeqCst, Ordering::SeqCst, |value| {
@@ -86,6 +87,7 @@ impl SharedPollState {
8687
&self,
8788
to_poll: u8,
8889
) -> Option<(u8, PollStateBomb<'_, impl FnOnce(&Self) -> u8>)> {
90+
#[allow(deprecated)] // fetch_update was renamed to try_update in rust 1.95.0
8991
let value = self
9092
.state
9193
.fetch_update(Ordering::SeqCst, Ordering::SeqCst, |value| {
@@ -121,6 +123,7 @@ impl SharedPollState {
121123
/// * `POLLING` phase can't start if some of the wakers are active
122124
/// So no wrapped waker can touch the inner waker's cell, it's safe to poll again.
123125
fn stop_polling(&self, to_poll: u8, will_be_woken: bool) -> u8 {
126+
#[allow(deprecated)] // fetch_update was renamed to try_update in rust 1.95.0
124127
self.state
125128
.fetch_update(Ordering::SeqCst, Ordering::SeqCst, |mut value| {
126129
let mut next_value = to_poll;
@@ -138,6 +141,7 @@ impl SharedPollState {
138141

139142
/// Toggles state to non-waking, allowing to start polling.
140143
fn stop_waking(&self) -> u8 {
144+
#[allow(deprecated)] // fetch_update was renamed to try_update in rust 1.95.0
141145
let value = self
142146
.state
143147
.fetch_update(Ordering::SeqCst, Ordering::SeqCst, |value| {

0 commit comments

Comments
 (0)