From 6ff06a9f7e01820e6b89344e9e48e9ec0e3254fa Mon Sep 17 00:00:00 2001 From: Ermal Kaleci Date: Fri, 24 Nov 2023 11:33:14 +0100 Subject: [PATCH] drop subscription on error --- src/middlewares/subscriptions/merge_subscription.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/middlewares/subscriptions/merge_subscription.rs b/src/middlewares/subscriptions/merge_subscription.rs index 5b438b0..5fb29fe 100644 --- a/src/middlewares/subscriptions/merge_subscription.rs +++ b/src/middlewares/subscriptions/merge_subscription.rs @@ -268,9 +268,9 @@ impl Middleware> for MergeSubscript } } Err(e) => { - // this should never happen - tracing::error!("subscription stream error {e:?}"); - unreachable!("subscription stream error {e:?}"); + // remote upstream subscription failed, drop subscription + tracing::trace!("subscription stream error {e}"); + break; } } }