io: format code

tokio/src/runtime/io/scheduled_io.rs

@@ -207,7 +207,7 @@ impl ScheduledIo {
     /// - `f`: a closure returning a new readiness value given the previous
     ///   readiness.
     pub(super) fn set_readiness(&self, tick_op: Tick, f: impl Fn(Ready) -> Ready) {
-        let update = |curr| {
+        let _ = self.readiness.fetch_update(AcqRel, Acquire, |curr| {
             // If the io driver is shut down, then you are only allowed to clear readiness.
             debug_assert!(SHUTDOWN.unpack(curr) == 0 || matches!(tick_op, Tick::Clear(_)));
 
@@ -220,12 +220,8 @@ impl ScheduledIo {
                 Tick::Clear(t) => t as usize,
                 Tick::Set => tick.wrapping_add(1) % MAX_TICK,
             };
-
             let ready = Ready::from_usize(READINESS.unpack(curr));
             Some(TICK.pack(new_tick, f(ready).as_usize()))
-        };
-        let _ = self.readiness.fetch_update(AcqRel, Acquire, |curr| {
-             ...
         });
     }