Function observedAtom

packages/vue/src/query.ts:448–460

(
  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
  }
)

  atom: () => Atom.Writable<Atom.PullResult<A, E>, void>
): StreamQueryView<A, E> => {
  const registry = injectRegistry()
  const atomRef = computed(atom)
  const atomResult = useAtomValue(() => atomRef.value)
  const result = computed(() => atomResult.value)
  const pull = () => registry.set(atomRef.value, void 0)
  const refresh = () => registry.refresh(atomRef.value)
  const awaitResult = () => awaitAtomResult(registry, atomRef.value)
  const pullAndAwait = () =>
    Effect.gen(function*() {
      pull()
      return yield* awaitResult()
    })
  const items = computed(() =>
    Option.getOrElse(
      Option.map(AsyncResult.value(result.value), (_) => _.items),
      () => []