rx-angular
diff --git a/‎apps/demos/src/app/rx-angular-pocs/cdk/utils/rxjs/observable/stateful-observable.ts
Copy file name to clipboardExpand all lines: apps/demos/src/app/rx-angular-pocs/cdk/utils/rxjs/observable/stateful-observable.ts
+4-4Lines changed: 4 additions & 4 deletions b/‎apps/demos/src/app/rx-angular-pocs/cdk/utils/rxjs/observable/stateful-observable.ts
Copy file name to clipboardExpand all lines: apps/demos/src/app/rx-angular-pocs/cdk/utils/rxjs/observable/stateful-observable.ts
+4-4Lines changed: 4 additions & 4 deletions
diff --git a/‎libs/state/selections/src/lib/accumulation-observable.ts
Copy file name to clipboardExpand all lines: libs/state/selections/src/lib/accumulation-observable.ts
+4-4Lines changed: 4 additions & 4 deletions b/‎libs/state/selections/src/lib/accumulation-observable.ts
Copy file name to clipboardExpand all lines: libs/state/selections/src/lib/accumulation-observable.ts
+4-4Lines changed: 4 additions & 4 deletions
@@ -55,10 +55,10 @@ export function createAccumulationObservable<T extends object>(
         (state, [slice, stateAccumulator]) => stateAccumulator(state, slice),
         {} as T
       ),
-      tap(
-        (newState) => (compositionObservable.state = newState),
-        (error) => console.error(error)
-      ),
+      tap({
+        next: (newState) => (compositionObservable.state = newState),
+        error: (error) => console.error(error),
+      }),
       catchError((e) => EMPTY)
     ),
     {
 
@@ -44,10 +44,10 @@ export function createAccumulationObservable<T extends object>(
         (state, [slice, stateAccumulator]) => stateAccumulator(state, slice),
         {} as T
       ),
-      tap(
-        (newState) => (compositionObservable.state = newState),
-        (error) => console.error(error)
-      ),
+      tap({
+        next: (newState) => (compositionObservable.state = newState),
+        error: (error) => console.error(error),
+      }),
       catchError((e) => EMPTY)
     ),
     {