Function makeInvocationEffect

packages/vue/src/mutate.ts:453–479

(input: unknown, source: Stream.Stream<any, any, any>)

    const r = (i: I, options?: MutationOptionsBase) =>
      invalidateQueries(self, options, queryInvalidator)(self.handler(i), i)
    return Object.assign(r, { id: self.id }) as any
  }
  return useMutation
}

/**
 * Returns a stream-based mutation factory for use with `streamFn`.
 * The outer Effect sets up per-invocation invalidation scaffolding
 * and returns a stream that triggers query invalidation via `Stream.ensuring` when it completes.
 *
 * Use with `streamFn` / `Command.streamFn(id)(mutateHandler, ...combinators)` so that
 * the command manages its own reactive state internally.
 */
export const makeStreamMutation2 = <RInvalidator>(queryInvalidator: QueryInvalidator<RInvalidator>) => {
  return (
    self: {
      id: string
      options?: ClientForOptions
      disableQueryInvalidation?: boolean
      handler: (i: any) => Stream.Stream<any, any, any>
    },
    mergedInvalidation?: MutationOptionsBase["queryInvalidation"]
  ) => {
    const invCache = buildInvalidateCache(self, mergedInvalidation, queryInvalidator)

    const makeInvocationEffect = (input: unknown, source: Stream.Stream<any, any, any>) =>
      Effect.gen(function*() {
        const keysRef = yield* Ref.make<ReadonlyArray<InvalidationKey>>([])
        // Server invalidation keys stay settlement-only: flushing them from `add` refetched
        // live queries once per chunk (One-Pick List storms). Write-deps flush once when the