Method constructor

src/core/ikari.ts:110–163

(readonly ayanami: Ayanami<State>, private readonly config: Readonly<Config<State>>)

  // eslint-disable-next-line @typescript-eslint/explicit-member-accessibility
  constructor(readonly ayanami: Ayanami<State>, private readonly config: Readonly<Config<State>>) {
    const [effectActions$, effectActions] = setupEffectActions(
      this.config.effects,
      this.state.state$,
    )

    const [reducerActions$, reducerActions] = setupReducerActions(
      this.config.reducers,
      this.state.getState,
    )

    const [immerReducerActions$, immerReducerActions] = setupImmerReducerActions(
      this.config.immerReducers,
      this.state.getState,
    )

    this.triggerActions = {
      ...effectActions,
      ...reducerActions,
      ...immerReducerActions,
      ...mapValues(this.config.defineActions, ({ next }) => next),
    }

    let effectActionsWithTerminate$: Observable<Action<any>>

    if (!isSSREnabled()) {
      effectActionsWithTerminate$ = effectActions$
    } else {
      effectActionsWithTerminate$ = effectActions$.pipe(
        takeUntil(this.terminate$.pipe(filter((action) => action === null))),
      )
    }

    this.subscription.add(
      effectActionsWithTerminate$.subscribe((action) => {
        this.log(action)
        this.handleAction(action)
      }),
    )

    this.subscription.add(
      reducerActions$.subscribe((action) => {
        this.log(action)
        this.handleAction(action)
      }),
    )

    this.subscription.add(
      immerReducerActions$.subscribe((action) => {
        this.log(action)
        this.handleAction(action)
      }),
    )
  }

  destroy(): void {
    this.subscription.unsubscribe()