Function makeQuery

packages/vue/src/query.ts:590–714

(_getRuntime: () => Context.Context<R>, getAtomRt: () => AtomClientRuntime)

  const refetch = () =>
    Effect.gen(function*() {
      yield* refreshAtomWithCurrentSpan(registry, atomRef.value)
      return yield* awaitResult()
    })
  const staleMs = staleTimeMsOf(normalizeQueryOptions(options))
  onMounted(() => {
    if (!enabledRef.value) return
    if (isStaleResult(registry.get(atomRef.value), staleMs)) refresh()
  })
  const data = computed(() => Option.getOrUndefined(AsyncResult.value(result.value)))

  return {
    result,
    data,
    awaitResult,
    refetch,
    refresh,
    registry,
    atom: atomRef
  }
}

export const makeQueryFamily = <R>(_getRuntime: () => Context.Context<R>, getAtomRt: () => AtomClientRuntime) => {
  const useQueryFamily: {
    <I, E, A, Request extends Req, Name extends string>(
      q: RequestHandlerWithInput<I, A, E, R, Request, Name>
    ): QueryAtomFamily<I, A, E>
  } = <I, E, A, Request extends Req, Name extends string>(
    q: RequestHandlerWithInput<I, A, E, R, Request, Name>
  ) => getQueryFamily(getAtomRt(), q)

  return useQueryFamily
}

export const makeQueryAtom = <R>(_getRuntime: () => Context.Context<R>, getAtomRt: () => AtomClientRuntime) => {
  const useQueryAtom: {
    <I, E, A, Request extends Req, Name extends string>(
      q: RequestHandlerWithInput<I, A, E, R, Request, Name>
    ): {
      <TData = A>(
        arg: I,
        options?: Omit<AtomQueryNewOptions<A, TData>, "select">
      ): Atom.Atom<AsyncResult.AsyncResult<A, E>>
    }
  } = <I, E, A, Request extends Req, Name extends string>(
    q: RequestHandlerWithInput<I, A, E, R, Request, Name>
  ) =>
  <TData = A>(
    arg: I,
    options?: Omit<AtomQueryNewOptions<A, TData>, "select">
  ) => queryAtomFor(getAtomRt(), q, arg, options)

  return useQueryAtom
}

export const makeQueryNew = <R>(_getRuntime: () => Context.Context<R>, getAtomRt: () => AtomClientRuntime) => {
  const useQueryNew: {
    <I, E, A, Request extends Req, Name extends string>(
      q: RequestHandlerWithInput<I, A, E, R, Request, Name>