Function SSREffect

src/ssr/express.ts:46–70

(options?: SSREffectOptions<Payload>)

// eslint-disable-next-line @typescript-eslint/explicit-module-boundary-types
export function SSREffect<T, Payload>(options?: SSREffectOptions<Payload>) {
  const { payloadGetter, skipFirstClientDispatch } = {
    payloadGetter: undefined,
    skipFirstClientDispatch: true,
    ...options,
  }

  return (target: T, method: string, descriptor: PropertyDescriptor) => {
    addDecorator(target, method, payloadGetter)
    if (!isSSREnabled() && skipFirstClientDispatch) {
      const originalValue = descriptor.value
      descriptor.value = function (
        this: any,
        action$: Observable<Payload>,
        state$?: Observable<any>,
      ) {
        if (Reflect.getMetadata(this.ssrLoadKey, this)) {
          return originalValue.call(this, action$.pipe(skip(1)), state$)
        }
        return originalValue.call(this, action$, state$)
      }
    }
    return Effect()(target, method, descriptor)
  }
}