drop subscription on error

AcalaNetwork · Nov 24, 2023 · 6ff06a9 · 6ff06a9
1 parent d534226
commit 6ff06a9
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/middlewares/subscriptions/merge_subscription.rs b/src/middlewares/subscriptions/merge_subscription.rs
@@ -268,9 +268,9 @@ impl Middleware<SubscriptionRequest, Result<(), StringError>> 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;
                                 }
                             }
                         }