Fix Subscription panics when unsubscribing from exhausted stream
@@ -22,9 +22,11 @@ impl SubscriptionStreams {
}
pub fn remove(&mut self, id: usize) {
+ if self.streams.contains(id) {
self.streams.remove(id);
}
}
+}
/// Subscription transport
///
