MarketTakers/arbiter
5
0
Fork 0
Code Issues 27 Pull Requests 4 Packages Projects Releases Wiki Activity

fix: return very important comment

Browse Source
This commit is contained in:
CleverWild
2026-03-19 17:52:11 +01:00
parent 77c3babec7
commit 434738bae5
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/crates/arbiter-server/src/actors/router/mod.rs
View File

@@ -99,6 +99,7 @@ async fn request_client_approval(
while let Some(result) = pool.join_next().await { while let Some(result) = pool.join_next().await {
match result { match result {
Ok(Ok(approved)) => { Ok(Ok(approved)) => {
// cancel other pending requests
let _ = cancel_tx.send(()); let _ = cancel_tx.send(());
return Ok(approved); return Ok(approved);
} }
@@ -153,7 +154,7 @@ impl MessageRouter {
ctx: &mut Context<Self, DelegatedReply<Result<bool, ApprovalError>>>, ctx: &mut Context<Self, DelegatedReply<Result<bool, ApprovalError>>>,
) -> DelegatedReply<Result<bool, ApprovalError>> { ) -> DelegatedReply<Result<bool, ApprovalError>> {
let (reply, Some(reply_sender)) = ctx.reply_sender() else { let (reply, Some(reply_sender)) = ctx.reply_sender() else {
panic!("Exptected `request_client_approval` to have callback channel"); panic!("Expected `request_client_approval` to have callback channel");
}; };
let weak_refs = self let weak_refs = self