From 78136e2734da9754580654677d0d30d80efb93f6 Mon Sep 17 00:00:00 2001
From: mpetrov <mpetrov@thingsboard.io>
Date: Wed, 10 Jul 2024 15:04:55 +0300
Subject: [PATCH] refactoring

---
 ...gateway-service-rpc-connector.component.ts | 31 ++++++++++---------
 1 file changed, 16 insertions(+), 15 deletions(-)

diff --git a/ui-ngx/src/app/modules/home/components/widget/lib/gateway/gateway-service-rpc-connector.component.ts b/ui-ngx/src/app/modules/home/components/widget/lib/gateway/gateway-service-rpc-connector.component.ts
index e35061a611..3027cafa8d 100644
--- a/ui-ngx/src/app/modules/home/components/widget/lib/gateway/gateway-service-rpc-connector.component.ts
+++ b/ui-ngx/src/app/modules/home/components/widget/lib/gateway/gateway-service-rpc-connector.component.ts
@@ -406,20 +406,21 @@ export class GatewayServiceRPCConnectorComponent implements OnInit, OnDestroy, C
   }
 
   private observeMQTTWithResponse(): void {
-    this.commandForm.get('withResponse').valueChanges.pipe(
-      filter(() => this.connectorType === ConnectorType.MQTT),
-      tap((isActive: boolean) => {
-        const responseTopicControl = this.commandForm.get('responseTopicExpression');
-        const responseTimeoutControl = this.commandForm.get('responseTimeout');
-        if (isActive) {
-          responseTopicControl.enable();
-          responseTimeoutControl.enable();
-        } else {
-          responseTopicControl.disable();
-          responseTimeoutControl.disable();
-        }
-      }),
-      takeUntil(this.destroy$),
-    ).subscribe();
+    if (this.connectorType === ConnectorType.MQTT) {
+      this.commandForm.get('withResponse').valueChanges.pipe(
+        tap((isActive: boolean) => {
+          const responseTopicControl = this.commandForm.get('responseTopicExpression');
+          const responseTimeoutControl = this.commandForm.get('responseTimeout');
+          if (isActive) {
+            responseTopicControl.enable();
+            responseTimeoutControl.enable();
+          } else {
+            responseTopicControl.disable();
+            responseTimeoutControl.disable();
+          }
+        }),
+        takeUntil(this.destroy$),
+      ).subscribe();
+    }
   }
 }