We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a787afb commit eeee73bCopy full SHA for eeee73b
libs/state/effects/src/lib/effects.service.ts
@@ -13,7 +13,7 @@ import {
13
import {
14
catchError,
15
filter,
16
- mapTo,
+ map,
17
mergeAll,
18
share,
19
takeUntil,
@@ -165,7 +165,10 @@ export class RxEffects implements OnDestroy$ {
165
}
166
const effectId = RxEffects.nextId++;
167
const destroy$ = (this.destroyers[effectId] = new Subject<void>());
168
- const applyBehavior = pipe(mapTo(effectId), takeUntil(destroy$));
+ const applyBehavior = pipe(
169
+ map(() => effectId),
170
+ takeUntil(destroy$),
171
+ );
172
if (fnOrObj != null) {
173
this.observables$.next(
174
from(obsOrSub).pipe(
0 commit comments