fix(cdk): share a single subscription to the underlying source observ…

…able between multiple subscribers (#3174)
taiga-family · Dec 20, 2022 · 29f7454 · 29f7454
1 parent 4cf7f0b
commit 29f7454
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 4 deletions.
diff --git a/projects/cdk/services/resize.service.ts b/projects/cdk/services/resize.service.ts
@@ -14,6 +14,7 @@ import {
     distinctUntilChanged,
     map,
     mapTo,
+    share,
     takeUntil,
     throttleTime,
 } from 'rxjs/operators';
@@ -34,6 +35,10 @@ export class TuiResizeService extends ResizeObserverService {
 
         return this.pipe(
             catchError(() =>
+                /**
+                 * @note: if not supported ResizeObserver
+                 * remove `catchError` after supports modern browsers
+                 */
                 animationFrame$.pipe(
                     throttleTime(POLLING_TIME),
                     map(
@@ -46,6 +51,7 @@ export class TuiResizeService extends ResizeObserverService {
             ),
             debounceTime(0),
             tuiZonefree(ngZone),
+            share(),
             takeUntil(destroy$),
         );
     }

diff --git a/projects/demo/src/modules/app/abstract.app.ts b/projects/demo/src/modules/app/abstract.app.ts
@@ -1,15 +1,15 @@
 import {Directive, ElementRef, HostBinding, OnInit} from '@angular/core';
 import {Router} from '@angular/router';
 import {TUI_DOC_PAGE_LOADED} from '@taiga-ui/addon-doc';
-import {tuiPure, TuiResizeService} from '@taiga-ui/cdk';
+import {TuiDestroyService, tuiPure, TuiResizeService} from '@taiga-ui/cdk';
 import {Observable} from 'rxjs';
 
 import {readyToScrollFactory} from './utils/ready-to-scroll-factory';
 import {TuiVersionMeta} from './version-manager/versions.constants';
 
 export const DEMO_PAGE_LOADED_PROVIDER = {
     provide: TUI_DOC_PAGE_LOADED,
-    deps: [ElementRef, TuiResizeService],
+    deps: [ElementRef, TuiResizeService, TuiDestroyService],
     useFactory: readyToScrollFactory,
 };
 

diff --git a/projects/demo/src/modules/app/app.component.ts b/projects/demo/src/modules/app/app.component.ts
@@ -29,8 +29,8 @@ import {TuiVersionMeta} from './version-manager/versions.constants';
     templateUrl: `./app.template.html`,
     styleUrls: [`./app.style.less`],
     providers: [
-        TuiDestroyService,
         TuiResizeService,
+        TuiDestroyService,
         DEMO_PAGE_LOADED_PROVIDER,
         TUI_VERSION_MANAGER_PROVIDERS,
     ],

diff --git a/projects/demo/src/modules/app/utils/ready-to-scroll-factory.ts b/projects/demo/src/modules/app/utils/ready-to-scroll-factory.ts
@@ -1,10 +1,11 @@
 import {ElementRef} from '@angular/core';
 import {Observable} from 'rxjs';
-import {debounceTime, map, startWith} from 'rxjs/operators';
+import {debounceTime, map, startWith, takeUntil} from 'rxjs/operators';
 
 export function readyToScrollFactory(
     hostElement: ElementRef<HTMLElement>,
     resize$: Observable<unknown>,
+    destroy$: Observable<unknown>,
 ): Observable<boolean> {
     return resize$.pipe(
         startWith(null),
@@ -19,5 +20,6 @@ export function readyToScrollFactory(
                 codeElements.every(el => el.querySelector(`.t-code`))
             );
         }),
+        takeUntil(destroy$),
     );
 }