Function makeStreamMutation2

packages/vue/src/mutate.ts:441–483

(queryInvalidator: QueryInvalidator<RInvalidator>)

  return useMutation
}

export const useMakeMutation = <RInvalidator>(queryInvalidator: QueryInvalidator<RInvalidator>) => {
  /**
   * Pass a function that returns an Effect, e.g from a client action.
   * Executes query cache invalidation based on default rules or provided option.
   * When `I = void` the input argument may be omitted.
   */
  const useMutation = <I, E, A, R, Request extends Req, Id extends string>(
    self: RequestHandlerWithInput<I, A, E, R, Request, Id>
  ): MutationFn<I, A, E, R, Id> => {
    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
        // first write arrives (job create → GetActiveJob) and again from `ensuring`.
        const invKeys = makeInvalidationKeysService(keysRef)
        const readsRef = yield* Ref.make(DataDependencies.empty())
        const writesRef = yield* Ref.make(DataDependencies.empty())