Added publish to get rid of connect error in refCount.js.

sclausen · Apr 18, 2018 · 75a01e7 · 75a01e7
1 parent e0e4da5
commit 75a01e7
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": "ngx-mqtt",
-  "version": "5.3.0",
+  "version": "5.4.0",
   "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
@@ -9,7 +9,7 @@ import { UsingObservable } from 'rxjs/observable/UsingObservable';
 import { Subject } from 'rxjs/Subject';
 import { Subscription, AnonymousSubscription } from 'rxjs/Subscription';
 import { merge } from 'rxjs/observable/merge';
-import { filter, refCount } from 'rxjs/operators';
+import { filter, publish, refCount } from 'rxjs/operators';
 
 import {
   IMqttClient,
@@ -163,6 +163,7 @@ export class MqttService {
           (subscription: AnonymousSubscription) => merge(rejected, this.messages))
         .pipe(
           filter((msg: IMqttMessage) => MqttService.filterMatchesTopic(filterString, msg.topic)),
+          publish(),
           refCount()
         );
     }