Update connect.ts

spotware · Sep 25, 2017 · 7bd0fb4 · 7bd0fb4
1 parent 8aaa456
commit 7bd0fb4
Show file tree

Hide file tree

Showing 3 changed files with 566 additions and 589 deletions.
diff --git a/lib/connect.js b/lib/connect.js
@@ -8,7 +8,7 @@ var Connect = (function () {
         this.adapterConnected = false;
         this.commandsAwaitingResponse = [];
         this.guaranteedCommandsToBeSent = [];
-        this.pushEvents = new rxjs_1.ReplaySubject(null);
+        this.pushEvents = new rxjs_1.ReplaySubject(1);
         this.instanceId = params.instanceId || 'connect';
         this.adapter = params.adapter;
         this.payloadTypesNotAwaitingResponse = params.payloadTypesNotAwaitingResponse || [];

diff --git a/lib/connect.ts b/lib/connect.ts
@@ -37,7 +37,7 @@ export class Connect {
     private adapterConnected = false;
     private commandsAwaitingResponse: CacheCommand[] = [];
     private guaranteedCommandsToBeSent: CacheCommand[] = [];
-    private pushEvents = new ReplaySubject<IMessage>(null);
+    private pushEvents = new ReplaySubject<IMessage>(1);
     private payloadTypesNotAwaitingResponse: number[];
 
     constructor(params: IConnectionParams) {