Subscribing to getSubscriptionConnectionObservable returns last known…

… state (#285)
Qminder · Jan 19, 2021 · 37e657c · 37e657c
1 parent 3d14116
commit 37e657c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "qminder-api",
-  "version": "3.0.0",
+  "version": "3.0.1",
   "description": "Qminder Javascript API. Makes it easy to leverage Qminder capabilities in your system.",
   "directories": {
     "test": "test"

diff --git a/src/services/GraphQLService.ts b/src/services/GraphQLService.ts
@@ -2,6 +2,7 @@ import WebSocket, {MessageData} from '../lib/websocket-web';
 import ApiBase, {GraphqlResponse} from '../api-base';
 import {Observable, Observer, Subject} from 'rxjs';
 import { GraphqlBatcher } from '../graphql-batcher';
+import { shareReplay } from "rxjs/operators";
 
 interface OperationMessage {
     id?: string;
@@ -57,7 +58,7 @@ class GraphQLService {
 
     private connectionStatus: ConnectionStatus;
     private connectionSubject = new Subject<ConnectionStatus>();
-    private connection$ = this.connectionSubject.pipe();
+    private connection$ = this.connectionSubject.pipe(shareReplay(1));
 
     private nextSubscriptionId: number = 1;