Function handle

packages/vue/src/mutate.ts:356–385

(eff: Effect.Effect<A, E, R>, input?: unknown)

                ),
                Effect.forkDetach({ startImmediately: true })
              )
            }
            if (awaitKeys.length > 0) {
              yield* queryInvalidator.invalidateAndAwait(awaitKeys)
            }
          })
        )
        .pipe(
          Effect.tap(Effect.sleep(0.1)), // allow for refs to update etc
          Effect.withSpan("client.query.invalidation", {}, { captureStackTrace: false })
        )
    })

  return invalidateCache
}

export const invalidateQueries = <RInvalidator>(
  self: { id: string; options?: ClientForOptions; disableQueryInvalidation?: boolean },
  options: MutationOptionsBase | undefined,
  queryInvalidator: QueryInvalidator<RInvalidator>
) => {
  const invalidateCache = buildInvalidateCache(self, options?.queryInvalidation, queryInvalidator)

  const select = options?.select

  const handle = <A, E, R>(eff: Effect.Effect<A, E, R>, input?: unknown) =>
    Effect.gen(function*() {
      const keysRef = yield* Ref.make<ReadonlyArray<InvalidationKey>>([])
      const readsRef = yield* Ref.make(DataDependencies.empty())
      const writesRef = yield* Ref.make(DataDependencies.empty())
      const dependencyRecorder = DataDependencies.makeDataDependencyRecorder(readsRef, writesRef)
      const result = yield* eff.pipe(
        Effect.provideService(InvalidationKeysFromServer, makeInvalidationKeysService(keysRef)),