Method toActions

modules/effects/src/effect_sources.ts:49–89

* @internal

()

   * @internal
   */
  toActions(): Observable<Action> {
    return this.pipe(
      groupBy((effectsInstance) =>
        isClassInstance(effectsInstance)
          ? getSourceForInstance(effectsInstance)
          : effectsInstance
      ),
      mergeMap((source$) => {
        return source$.pipe(groupBy(effectsInstance));
      }),
      mergeMap((source$) => {
        const effect$ = source$.pipe(
          exhaustMap((sourceInstance) => {
            return resolveEffectSource(
              this.errorHandler,
              this.effectsErrorHandler
            )(sourceInstance);
          }),
          map((output) => {
            reportInvalidActions(output, this.errorHandler);
            return output.notification;
          }),
          filter(
            (notification): notification is ObservableNotification<Action> =>
              notification.kind === 'N' && notification.value != null
          ),
          dematerialize()
        );

        // start the stream with an INIT action
        // do this only for the first Effect instance
        const init$ = source$.pipe(
          take(1),
          filter(isOnInitEffects),
          map((instance) => instance.ngrxOnInitEffects())
        );

        return merge(effect$, init$);
      })
    );
  }
}

function effectsInstance(sourceInstance: any) {