Fixed indentation and created new version for #86.

sclausen · May 8, 2018 · 625ae76 · 625ae76
1 parent 83b59ed
commit 625ae76
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 11 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "ngx-mqtt",
-  "version": "6.1.0",
+  "version": "6.1.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
@@ -144,15 +144,15 @@ export class MqttService {
           () => {
             const subscription: Subscription = new Subscription();
             this.client.subscribe(filterString, (err, granted: ISubscriptionGrant[]) => {
-              if(granted) { // granted can be undefined when an error occurs when the client is disconnecting
-                  granted.forEach((granted_: ISubscriptionGrant) => {
-                      if (granted_.qos === 128) {
-                          delete this.observables[granted_.topic];
-                          this.client.unsubscribe(granted_.topic);
-                          rejected.error(`subscription for '${granted_.topic}' rejected!`);
-                      }
-                      this._onSuback.emit({filter: filterString, granted: granted_.qos !== 128});
-                  });
+              if (granted) { // granted can be undefined when an error occurs when the client is disconnecting
+                granted.forEach((granted_: ISubscriptionGrant) => {
+                  if (granted_.qos === 128) {
+                    delete this.observables[granted_.topic];
+                    this.client.unsubscribe(granted_.topic);
+                    rejected.error(`subscription for '${granted_.topic}' rejected!`);
+                  }
+                  this._onSuback.emit({filter: filterString, granted: granted_.qos !== 128});
+                });
               }
             });
             subscription.add(() => {