Hare/yoi
1
1
Fork 0
Code Actions Packages Releases Activity

test: clean up compact event assertion

Browse Source
This commit is contained in:
Keisuke Hirata 2026-05-24 09:39:57 +09:00
parent 2109733cb7
commit 7054a179d4
No known key found for this signature in database
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
crates/pod/tests/compact_events_test.rs
View File

@ -786,7 +786,6 @@ async fn controller_compact_method_emits_start_and_done() {
handle.send(Method::Compact).await.expect("send compact"); handle.send(Method::Compact).await.expect("send compact");
let mut saw_start = false; let mut saw_start = false;
let mut saw_done = false;
loop { loop {
match tokio::time::timeout(std::time::Duration::from_secs(2), rx.recv()) match tokio::time::timeout(std::time::Duration::from_secs(2), rx.recv())
.await .await
@ -795,7 +794,6 @@ async fn controller_compact_method_emits_start_and_done() {
{ {
Event::CompactStart => saw_start = true, Event::CompactStart => saw_start = true,
Event::CompactDone { .. } => { Event::CompactDone { .. } => {
saw_done = true;
break; break;
} }
Event::CompactFailed { error } => panic!("manual compact failed: {error}"), Event::CompactFailed { error } => panic!("manual compact failed: {error}"),
@ -804,6 +802,5 @@ async fn controller_compact_method_emits_start_and_done() {
} }
assert!(saw_start, "manual compact should emit CompactStart"); assert!(saw_start, "manual compact should emit CompactStart");
assert!(saw_done, "manual compact should emit CompactDone");
let _ = handle.send(Method::Shutdown).await; let _ = handle.send(Method::Shutdown).await;
} }