v0.3.11-pre.006-fix.001

This commit is contained in:
2026-09-08 11:03:31 +02:00
parent 61d8b1dee2
commit 355c5d1e9a
3 changed files with 101 additions and 4 deletions

View File

@@ -1,5 +1,5 @@
// file: crates/ksp-worker-raw-transaction-ingest-lib/unit_tests/admission.rs
// version: 1
// version: 2
fn material(
network: &str,
@@ -148,8 +148,8 @@ async fn pre_006_stop_preempts_a_blocked_sender_without_silent_post_stop_admissi
};
return tokio::select! {
biased;
_changed = blocked_stop.changed() => false
result = blocked_sender.send(blocked_ingress) => result.is_ok()
_changed = blocked_stop.changed() => false,
result = blocked_sender.send(blocked_ingress) => result.is_ok(),
};
});
tokio::task::yield_now().await;