From 2d6d31623b35a54b6c60f49a4a998708b95fb61f Mon Sep 17 00:00:00 2001
From: yksolanki9 <yashsolanki1709@gmail.com>
Date: Sat, 24 Dec 2022 18:00:43 +0530
Subject: [PATCH] Unsubscribe to observable once component is destroyed

---
 apps/client/src/app/services/import-activities.service.ts | 4 ++--
 .../lib/activities-table/activities-table.component.ts    | 8 +++++---
 2 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/apps/client/src/app/services/import-activities.service.ts b/apps/client/src/app/services/import-activities.service.ts
index da120217b..18868c919 100644
--- a/apps/client/src/app/services/import-activities.service.ts
+++ b/apps/client/src/app/services/import-activities.service.ts
@@ -79,8 +79,8 @@ export class ImportActivitiesService {
           })
         )
         .subscribe({
-          next: (importedActivities) => {
-            resolve(importedActivities.activities);
+          next: (data) => {
+            resolve(data.activities);
           }
         });
     });
diff --git a/libs/ui/src/lib/activities-table/activities-table.component.ts b/libs/ui/src/lib/activities-table/activities-table.component.ts
index 2518ba1be..315717cab 100644
--- a/libs/ui/src/lib/activities-table/activities-table.component.ts
+++ b/libs/ui/src/lib/activities-table/activities-table.component.ts
@@ -164,9 +164,11 @@ export class ActivitiesTableComponent implements OnChanges, OnDestroy {
   }
 
   ngOnInit() {
-    this.selectedRows.changed.subscribe((selectedRows) => {
-      this.selectedActivities.emit(selectedRows.source.selected);
-    });
+    this.selectedRows.changed
+      .pipe(takeUntil(this.unsubscribeSubject))
+      .subscribe((selectedRows) => {
+        this.selectedActivities.emit(selectedRows.source.selected);
+      });
   }
 
   public onChangePage(page: PageEvent) {