Class Ikari

src/core/ikari.ts:81–201

}

export class Ikari<State> {
  static createAndBindAt<S>(target: Ayanami<S>, config: Config<S>): Ikari<S> {
    const createdIkari = this.getFrom(target)

    if (createdIkari) {
      return createdIkari
    } else {
      const ikari = new Ikari(target, config)
      Reflect.defineMetadata(ikariSymbol, ikari, target)
      return ikari
    }
  }

  static getFrom<S>(target: { defaultState: S }): Ikari<S> | undefined {
    return Reflect.getMetadata(ikariSymbol, target)
  }

  state = createState(this.config.defaultState)

  effectActionFactories = this.config.effectActionFactories

  triggerActions: TriggerActions = {}

  subscription = new Subscription()

  // @internal
  terminate$ = new Subject<typeof TERMINATE_ACTION | null>()

  // 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(