Added warning for missing streams.

Widdershin · Mar 2, 2016 · 8250e59 · 8250e59
1 parent c825638
commit 8250e59
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/restartable.js b/src/restartable.js
@@ -179,7 +179,11 @@ export default function restartable (driver, opts = {}) {
       newLog$.take(1).subscribe(newLog => {
         function scheduleEvent (historicEvent) {
           scheduler.scheduleAbsolute({}, historicEvent.time, () => {
-            streams[historicEvent.identifier].onNext(historicEvent.event);
+            if (streams[historicEvent.identifier]) {
+              streams[historicEvent.identifier].onNext(historicEvent.event);
+            } else {
+              console.error('Missing replay stream ', historicEvent.identifier)
+            }
           });
         }