Function makeQueryNew

packages/vue/src/query.ts:564–588

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

  options?: (AtomQueryNewOptions<A, TData> | CustomUseQueryOptions<A, E, TData>) & {
    readonly mode?: "optional"
  }
): QueryView<TData, E> => {
  const atomRt = getAtomRt()
  const registry = injectRegistry()
  const [req, enabledRef] = optionValue<I>(arg, options)
  const family = getQueryFamily(atomRt, q)
  const atomRef = computed(() => enabledRef.value ? observedAtom(family(req.value), options) : disabledQueryAtom)
  // useAtomValue returns Readonly<Ref>, not ComputedRef — re-wrap before withDataFallback / QueryView.
  const rawAtomResult = useAtomValue(() => atomRef.value)
  const rawResult = computed(() => rawAtomResult.value)
  // `initialData` / `placeholderData` display fallback (old `.query()` API). Applied only while the
  // result is still Initial; Failures/Success pass through unmasked. Neither is written to cache
  // (the base atom stays Initial, so the mount-staleness check still triggers the real fetch). The
  // fallback runs PRE-select, matching TanStack (`initialData`/`placeholderData` are TQueryData).
  const fallbackResult = withDataFallback(rawResult, options)
  const select = options?.select
  const result = (select
    ? computed(() => AsyncResult.map(fallbackResult.value, select))
    : fallbackResult) as ComputedRef<AsyncResult.AsyncResult<TData, E>>
  const refresh = () => registry.refresh(atomRef.value)
  const awaitResult = () =>
    select
      ? awaitAtomResult(registry, atomRef.value).pipe(Effect.map(select))
      : awaitAtomResult(registry, atomRef.value)
  const refetch = () =>
    Effect.gen(function*() {
      yield* refreshAtomWithCurrentSpan(registry, atomRef.value)
      return yield* awaitResult()