Add observable api for subscription hub.

1 files changed, 12 insertions, 0 deletions

diff --git a/Timeline/ClientApp/src/app/data/SubscriptionHub.ts b/Timeline/ClientApp/src/app/data/SubscriptionHub.ts
index 8a74c939..24f1885d 100644
--- a/Timeline/ClientApp/src/app/data/SubscriptionHub.ts
+++ b/Timeline/ClientApp/src/app/data/SubscriptionHub.ts
@@ -1,4 +1,5 @@
 import { pull } from 'lodash';

+import { Observable } from 'rxjs';

 

 export type Subscriber<TData> = (data: TData) => void;

 

@@ -155,6 +156,17 @@ export class SubscriptionHub<TKey, TData>
     return line.subscribe(subscriber);

   }

 

+  getObservable(key: TKey): Observable<TData> {

+    return new Observable((observer) => {

+      const sub = this.subscribe(key, (data) => {

+        observer.next(data);

+      });

+      return () => {

+        sub.unsubscribe();

+      };

+    });

+  }

+

   getLine(key: TKey): ISubscriptionLine<TData> | null {

     const keyString = this.keyToString(key);

     return this.subscriptionLineMap.get(keyString)?.line ?? null;