Function makeQueryView

packages/vue/src/query.ts:485–529

(
  getAtomRt: () => AtomClientRuntime,
  q: QueryFamilyDescriptor<I, A, E>,
  arg: I | WatchSource<I> | undefined | WatchSource<Option.Option<I>>,
  options?: (AtomQueryNewOptions<A, TData> | CustomUseQueryOptions<A, E, TData>) & {
    readonly mode?: "optional"
  }
)

    registry,
    atom: atomRef
  }
}

const optionValue = <I>(
  arr: I | WatchSource<I> | undefined | WatchSource<Option.Option<I>>,
  options?: { readonly mode?: "optional"; readonly enabled?: MaybeRefOrGetter<boolean | undefined> }
): readonly [{ readonly value: I }, ComputedRef<boolean>] => {
  if (options?.mode === "optional") {
    const getOption: () => Option.Option<I> = typeof arr === "function"
      ? arr as () => Option.Option<I>
      : () => (arr as { value: Option.Option<I> }).value
    return [
      {
        get value() {
          return Option.getOrUndefined(getOption()) as I
        }
      },
      computed(() => Option.isSome(getOption()))
    ] as const
  }
  const req = !arr
    ? ({ value: undefined as I })
    : typeof arr === "function"
    ? ({
      get value() {
        return (arr as any)()
      }
    })
    : (ref(arr) as any)
  const enabled = options?.enabled
  return [req, computed(() => enabled === undefined ? true : !!toValue(enabled))] as const
}

const observedAtom = <A, E>(
  atom: Atom.Atom<AsyncResult.AsyncResult<A, E>>,
  options?: {
    readonly staleTime?: number
    readonly gcTime?: number | "infinity"
    readonly idleTTL?: number | "infinity"
    readonly refetchOnWindowFocus?: boolean
    readonly revalidateOnFocus?: boolean
    readonly structuralSharing?: boolean
    readonly refetchInterval?: number
    readonly refreshEvery?: number
    readonly live?: boolean | LiveQueryOptions
    readonly invalidation?: QueryInvalidationMode
  }
): Atom.Atom<AsyncResult.AsyncResult<A, E>> =>