Handled exception on LinkedStream callbacks
@@ -113,7 +113,12 @@ class MessageCallback(object):
stream._metadata = {h: {'id': hid, 'events': self.on_events}
for h, hid in handle_ids.items()}
streams.append(stream)
+
+ try:
Stream.trigger(streams)
+ except Exception as e:
+ raise e
+ finally:
for stream in streams:
stream._metadata = {}
