Function streamQueryAtomFor

packages/vue/src/query.ts:719–727

(
  rt: AtomClientRuntime,
  q: StreamQueryFamilyDescriptor<I, A, E>,
  arg: I,
  options?: AtomStreamQueryOptions
)

  ) =>
  <TData = A>(
    arg: I | WatchSource<I> | undefined | WatchSource<Option.Option<I>>,
    options?: any
  ) => {
    const view = makeQueryView<I, A, E, TData>(getAtomRt, q, arg, options)

    // 4th element is internal-only; the public `.suspense()` Promise boundary lives in makeClient.
    const handle = {
      awaitResult: view.awaitResult,
      refetch: view.refetch,
      refresh: view.refresh,
      registry: view.registry,
      atom: view.atom