We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 99416a6 commit 0a0b2d5Copy full SHA for 0a0b2d5
tests/mpsc-close.rs
@@ -55,7 +55,7 @@ fn stress_try_send_as_receiver_closes() {
55
let (command_tx, command_rx) = channel::<TestRx>(0);
56
(
57
TestTask {
58
- command_rx,
+ command_rx: command_rx,
59
test_rx: None,
60
countdown: 0, // 0 means no countdown is in progress.
61
},
@@ -98,7 +98,7 @@ fn stress_try_send_as_receiver_closes() {
98
for i in 0..AMT {
99
let (mut test_tx, rx) = channel(0);
100
let poll_count = i % MAX_COUNTDOWN;
101
- cmd_tx.try_send(TestRx { rx, poll_count }).unwrap();
+ cmd_tx.try_send(TestRx { rx: rx, poll_count: poll_count }).unwrap();
102
let mut prev_weak: Option<Weak<()>> = None;
103
let mut attempted_sends = 0;
104
let mut successful_sends = 0;
0 commit comments