fix(lib): fix SingleAppBoundarySharingStrategy for late components

Use ReplaySubject with buffer set to Infinity for boundaries so they are stored and replayed for every new subscriber of component
gund · Jul 14, 2020 · fbf48c1 · fbf48c1
1 parent c7b67b9
commit fbf48c1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...lement-boundary/src/lib/boundary-sharing-strategy/single-app-boundary-sharing-strategy.ts b/...lement-boundary/src/lib/boundary-sharing-strategy/single-app-boundary-sharing-strategy.ts
@@ -1,5 +1,5 @@
 import { Injectable } from '@angular/core';
-import { Observable, Subject } from 'rxjs';
+import { Observable, ReplaySubject } from 'rxjs';
 import { scan, shareReplay } from 'rxjs/operators';
 
 import { ElementBoundary } from '../types';
@@ -11,7 +11,7 @@ import { BoundarySharingStrategy } from './boundary-sharing-strategy';
 @Injectable({ providedIn: 'root' })
 export class SingleAppBoundarySharingStrategy
   implements BoundarySharingStrategy {
-  private readonly addBoundary$ = new Subject<ElementBoundary>();
+  private readonly addBoundary$ = new ReplaySubject<ElementBoundary>(Infinity);
 
   private readonly boundaries$ = this.addBoundary$.pipe(
     scan((acc, boundary) => [...acc, boundary], [] as ElementBoundary[]),