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;