diff options
Diffstat (limited to 'src/sync/mod.rs')
| -rw-r--r-- | src/sync/mod.rs | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/src/sync/mod.rs b/src/sync/mod.rs index 2efcbd7..412cd16 100644 --- a/src/sync/mod.rs +++ b/src/sync/mod.rs | |||
| @@ -676,10 +676,14 @@ impl SyncManager { | |||
| 676 | .position(|b| b.outstanding_subs.contains(&sub_id)); | 676 | .position(|b| b.outstanding_subs.contains(&sub_id)); |
| 677 | 677 | ||
| 678 | let Some(batch_idx) = batch_index else { | 678 | let Some(batch_idx) = batch_index else { |
| 679 | tracing::warn!( | 679 | // Live subscriptions (limit:0, no auto-close) are not tracked in PendingBatch. |
| 680 | // They complete immediately with EOSE (no historic events) and stay open for new events. | ||
| 681 | // Observed in production: sync_live() subscriptions trigger this path (expected). | ||
| 682 | // Also possible: duplicate/late EOSE from relay after batch already completed. | ||
| 683 | tracing::trace!( | ||
| 680 | relay = %relay_url, | 684 | relay = %relay_url, |
| 681 | sub_id = %sub_id, | 685 | sub_id = %sub_id, |
| 682 | "EOSE received for unknown subscription" | 686 | "EOSE received for subscription not tracked in batch (live subscription or late EOSE)" |
| 683 | ); | 687 | ); |
| 684 | return; | 688 | return; |
| 685 | }; | 689 | }; |