diff options
Diffstat (limited to 'src/sync/relay_connection.rs')
| -rw-r--r-- | src/sync/relay_connection.rs | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/sync/relay_connection.rs b/src/sync/relay_connection.rs index bc4b59e..fdb32cb 100644 --- a/src/sync/relay_connection.rs +++ b/src/sync/relay_connection.rs | |||
| @@ -256,7 +256,8 @@ impl RelayConnection { | |||
| 256 | tracing::info!(relay = %url, message = %msg, "Relay closed subscription"); | 256 | tracing::info!(relay = %url, message = %msg, "Relay closed subscription"); |
| 257 | let _ = | 257 | let _ = |
| 258 | event_sender.send(RelayEvent::Closed(msg.to_string())).await; | 258 | event_sender.send(RelayEvent::Closed(msg.to_string())).await; |
| 259 | break; | 259 | // Don't break - CLOSED is subscription-specific, not connection-specific |
| 260 | // The event loop should continue running for other active subscriptions | ||
| 260 | } | 261 | } |
| 261 | _ => {} | 262 | _ => {} |
| 262 | }, | 263 | }, |