From 8beb712c5492dd77e81f46cb67752615f582ecf4 Mon Sep 17 00:00:00 2001
From: Dan Percic <dan@devplant.ro>
Date: Fri, 12 Nov 2021 01:34:37 +0200
Subject: [PATCH] get entity changed

---
 src/lib/listing/services/entities.service.ts | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/src/lib/listing/services/entities.service.ts b/src/lib/listing/services/entities.service.ts
index 345adc7..90a241f 100644
--- a/src/lib/listing/services/entities.service.ts
+++ b/src/lib/listing/services/entities.service.ts
@@ -1,9 +1,9 @@
 import { Inject, Injectable, InjectionToken, Injector, Optional } from '@angular/core';
 import { BehaviorSubject, Observable, Subject } from 'rxjs';
-import { map, tap } from 'rxjs/operators';
+import { filter, map, startWith, tap } from 'rxjs/operators';
 import { IListable } from '../models';
 import { GenericService, QueryParam } from '../../services';
-import { getLength, List, mapEach, shareDistinctLast } from '../../utils';
+import { getLength, List, mapEach, shareDistinctLast, shareLast } from '../../utils';
 
 /**
  * This should be removed when refactoring is done
@@ -59,6 +59,14 @@ export class EntitiesService<E extends IListable, I = E> extends GenericService<
         }
     }
 
+    getEntityChanged$(entityId: string): Observable<E | undefined> {
+        return this.entityChanged$.pipe(
+            filter(entity => entity.id === entityId),
+            startWith(this.find(entityId)),
+            shareLast(),
+        );
+    }
+
     setEntities(newEntities: E[]): void {
         this._all$.next(newEntities);
     }