aljaz/breez-sdk-liquid
1
0
Fork 0
mirror of https://github.com/aljazceru/breez-sdk-liquid.git synced 2026-01-31 11:54:24 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix status stream task shutdown (#935)

Browse Source
This commit is contained in:
Daniel Granhão
2025-05-27 11:19:40 +01:00
committed by GitHub
parent 8301805bac
commit 0bc2dbe899
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
lib/core/src/swapper/boltz/status_stream.rs
View File

@@ -46,6 +46,18 @@ impl<P: ProxyUrlFetcher> SwapperStatusStream for BoltzSwapper<P> {
tokio::spawn(async move {
loop {
debug!("Start of ws stream loop");
match shutdown.has_changed() {
Ok(true) => {
info!("Received shutdown signal, exiting Status Stream loop");
return;
}
Ok(false) => {}
Err(_) => {
warn!("Shutdown channel was closed, exiting Status Stream loop");
return;
}
}
let mut request_stream = self.request_notifier.subscribe();
let client = match swapper.get_boltz_client().await {
Ok(client) => client,