removed now superfluent rxjs code and added parameter to publishReplay.

sclausen · Jun 21, 2018 · d05ac86 · d05ac86
1 parent 430c8df
commit d05ac86
Show file tree

Hide file tree

Showing 4 changed files with 2 additions and 177 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "ngx-mqtt",
-  "version": "6.3.0",
+  "version": "6.3.1",
   "description": "ngx mqtt client library",
   "main": "bundles/ngx-mqtt.min.js",
   "module": "./src/index.js",

diff --git a/src/mqtt.service.ts b/src/mqtt.service.ts
@@ -143,7 +143,7 @@ export class MqttService {
    * Every new subscriber gets the latest message.
    */
   public observeRetained(filterString: string): Observable<IMqttMessage> {
-    return this._generalObserve(filterString, () => publishReplay());
+    return this._generalObserve(filterString, () => publishReplay(1));
   }
 
   /**

diff --git a/src/rxjs/CoditionalReplaySubject.ts b/src/rxjs/CoditionalReplaySubject.ts
diff --git a/src/rxjs/operators/publishReplayConditionally.ts b/src/rxjs/operators/publishReplayConditionally.ts