fix(stream): correct typing issue when detecting DebounceRenderStrategy

Author: michaelbe812

libs/stream/src/lib/types/render-strategies.ts

@@ -50,7 +50,7 @@ export interface DebounceRenderStrategy extends RenderStrategy {
   debounceInMs: number;
 }
 
-export type RenderStrategies = DefaultRenderStategy | ViewportRenderStrategy | ThrottleRenderStrategy;
+export type RenderStrategies = DefaultRenderStategy | ViewportRenderStrategy | ThrottleRenderStrategy | DebounceRenderStrategy;
 
 /**
  * @description

libs/stream/src/lib/util/setup-operator.spec.ts

@@ -0,0 +1,45 @@
+import {setupOperator$} from "./setup-operator";
+import {debounceTime, Observable, of, pipe, throttleTime} from "rxjs";
+import {RenderStrategies} from "../types/render-strategies";
+import {subscribeSpyTo} from "@hirez_io/observer-spy";
+
+describe(`${setupOperator$.name}`, () => {
+  it('should emit throttleTime-operator for ThrottleStrategy', () => {
+    const renderStrategy$: Observable<RenderStrategies> = of({type: 'throttle', throttleInMs: 1000});
+
+    const operator$ = setupOperator$(renderStrategy$);
+
+    const result = subscribeSpyTo(operator$);
+
+    expect(result.getLastValue()).toEqual(throttleTime(1000));
+  })
+  it('should emit debounce-operator for DebounceStrategy', () => {
+    const renderStrategy$: Observable<RenderStrategies> = of({type: 'debounce', debounceInMs: 1000});
+
+    const operator$ = setupOperator$(renderStrategy$);
+
+    const result = subscribeSpyTo(operator$);
+
+    expect(result.getLastValue()).toEqual(debounceTime(1000));
+  })
+
+  it('should emit empty-operator for DefaultStrategy', () => {
+    const renderStrategy$: Observable<RenderStrategies> = of({type: 'default'});
+
+    const operator$ = setupOperator$(renderStrategy$);
+
+    const result = subscribeSpyTo(operator$);
+
+    expect(result.getLastValue()).toEqual(pipe());
+  });
+
+  it('should emit empty-operator when no strategy matches', () => {
+    const renderStrategy$: Observable<RenderStrategies> = of(null as unknown as RenderStrategies);
+
+    const operator$ = setupOperator$(renderStrategy$);
+
+    const result = subscribeSpyTo(operator$);
+
+    expect(result.getLastValue()).toEqual(pipe());
+  });
+});

libs/stream/src/lib/util/setup-operator.ts

@@ -21,7 +21,6 @@ export function setupOperator$(renderStrategy$$: Observable<RenderStrategies>) {
       }
 
       if (isDebounceRenderStrategy(strategy)) {
-        // @ts-ignore todo fix typing issue
         return of(debounceTime(strategy.debounceInMs));
       }