fix(messaging): effects output event$ is not multicasted
MODIFY
packages/core/src/effects/effects.combiner.ts
packages/core/src/effects/effects.combiner.ts
import { Observable, merge } from 'rxjs';
+import { share } from 'rxjs/operators';
import { Effect, EffectContext } from './effects.interface';
export const combineMiddlewares = <T, U>
@@ -9,4 +10,4 @@ export const combineMiddlewares = <T, U>
export const combineEffects = <T, U, V>
(...effects: Effect<T, U, V>[]) =>
(input$: Observable<T>, ctx: EffectContext<V>): Observable<U> =>
- merge(...effects.map(effect => effect(input$, ctx)));
+ merge(...effects.map(effect => effect(input$, ctx))).pipe(share());

fix(messaging): effects output event$ is not multicasted