Function useAtomStreamQuery

packages/vue/src/query.ts:375–416

(
  atom: () => Atom.Writable<Atom.PullResult<A, E>, void>
)

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

export const useAtomSuspense = <A, E>(
  atom: () => Atom.Atom<AsyncResult.AsyncResult<A, E>>
): Promise<SuspenseQueryView<A, E>> => {
  const [{ view, data }, isMounted, signal] = useScopedSuspenseSetup(() => {
    const view = useAtomQuery(atom)
    const data = latestDefined(() => view.data.value, "atom suspense")
    return { view, data }
  })

  const eff = Effect.gen(function*() {
    const exit = yield* view.awaitResult().pipe(Effect.exit)
    if (!isMounted.value) {
      return yield* Effect.interrupt
    }
    if (Exit.isFailure(exit)) {
      return yield* Exit.failCause(exit.cause)
    }

    const fetch = (_options?: RefetchOptions) => view.refetch()
    const handle = {
      awaitResult: view.awaitResult,
      refetch: view.refetch,
      refresh: view.refresh,
      registry: view.registry,
      atom: view.atom
    }
    return Object.assign(
      [
        view.result,
        data,
        fetch,
        handle
      ] as const,
      {
        ...view,
        data