Merge pull request #39 from BoffinsDev/master

Assertions
Widdershin · Mar 3, 2016 · d16b11d · d16b11d
2 parents c825638 + 8250e59
commit d16b11d
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)
+            }
           });
         }