We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent aaa6de7 commit f63096eCopy full SHA for f63096e
library/std/src/sync/mpsc/shared.rs
@@ -248,7 +248,11 @@ impl<T> Packet<T> {
248
// Returns true if blocking should proceed.
249
fn decrement(&self, token: SignalToken) -> StartResult {
250
unsafe {
251
- assert_eq!(self.to_wake.load(Ordering::SeqCst), 0, "This is a known bug in rust. See https://github.com/rust-lang/rust/issues/39364");
+ assert_eq!(
252
+ self.to_wake.load(Ordering::SeqCst),
253
+ 0,
254
+ "This is a known bug in rust. See https://github.com/rust-lang/rust/issues/39364"
255
+ );
256
let ptr = token.cast_to_usize();
257
self.to_wake.store(ptr, Ordering::SeqCst);
258
0 commit comments