Function invalidateQueries

packages/vue/src/mutate.ts:347–388

(
  self: { id: string; options?: ClientForOptions; disableQueryInvalidation?: boolean },
  options: MutationOptionsBase | undefined,
  queryInvalidator: QueryInvalidator<RInvalidator>
)

            writeDependencies: [...writeDependencies]
          }),
          // refetch + AWAIT every live query registered under these keys, so by the time the
          // mutation resolves the affected queries are fresh.
          Effect.gen(function*() {
            if (softKeys.length > 0) {
              yield* (queryInvalidator.invalidateSoft?.(softKeys) ?? Effect.void).pipe(
                Effect.catchCause((cause) =>
                  reportRuntimeError(cause, { invalidation: "soft", keys: softKeys }).pipe(Effect.asVoid)
                ),
                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)),
        Effect.provideService(DataDependencies.DataDependencyRecorder, dependencyRecorder),
        Effect.onExit((exit) =>
          Effect.gen(function*() {