Skip to content

Commit 2bc850e

Browse files
emilkclaude
andcommitted
Fix new ignored_unit_patterns hits from main
New `select!` arms landed on main after this branch was written. Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
1 parent a259eeb commit 2bc850e

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

‎datafusion/execution/src/async_stream.rs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -401,7 +401,7 @@ mod test {
401401

402402
let s = async_stream(|mut emitter| async move {
403403
select! {
404-
_ = do_stuff_async() => emitter.emit(()).await,
404+
() = do_stuff_async() => emitter.emit(()).await,
405405
else => emitter.emit(()).await,
406406
}
407407
});
@@ -421,8 +421,8 @@ mod test {
421421

422422
let s = async_stream(|mut emitter| async move {
423423
select! {
424-
_ = do_stuff_async() => emitter.emit("hey").await,
425-
_ = more_async_work() => emitter.emit("hey").await,
424+
() = do_stuff_async() => emitter.emit("hey").await,
425+
() = more_async_work() => emitter.emit("hey").await,
426426
else => emitter.emit("hey").await,
427427
}
428428
});
@@ -572,7 +572,7 @@ mod test {
572572

573573
let _ = async_stream(|mut emitter| async move {
574574
select! {
575-
_ = do_stuff_async() => {
575+
() = do_stuff_async() => {
576576
let another_s = async_try_stream(|mut inner_emitter| async move {
577577
inner_emitter.emit(()).await;
578578
Ok(())

0 commit comments

Comments
 (0)