fix(ipc): break out of service loop when response stream is closed (#22710)

This commit is contained in:
MagicJoshh
2026-03-02 12:42:12 -06:00
committed by GitHub
parent a684714f40
commit 0e14f1a8a3

View File

@@ -532,9 +532,8 @@ async fn to_ipc_service<S, T>(
break
}
item = rx_item.next() => {
if let Some(item) = item {
conn.push_back(item.to_string());
}
let Some(item) = item else { break };
conn.push_back(item.to_string());
}
_ = &mut stopped => {
// shutdown