We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 445325b commit 4cb96cdCopy full SHA for 4cb96cd
1 file changed
rclrs/src/wait_set/wait_set_runner.rs
@@ -140,7 +140,7 @@ impl WaitSetRunner {
140
// TODO(@mxgrey): SmallVec would be better suited here if we are
141
// okay with adding that as a dependency.
142
let mut new_waitables = Vec::new();
143
- while let Ok(Some(new_waitable)) = self.waitable_receiver.try_next() {
+ while let Ok(new_waitable) = self.waitable_receiver.try_recv() {
144
new_waitables.push(new_waitable);
145
}
146
if !new_waitables.is_empty() {
@@ -152,7 +152,7 @@ impl WaitSetRunner {
152
153
154
155
- while let Ok(Some(task)) = self.task_receiver.try_next() {
+ while let Ok(task) = self.task_receiver.try_recv() {
156
task(&mut *self.payload);
157
158
0 commit comments