Function observedStreamAtom

packages/vue/src/query.ts:462–473

(
  atom: Atom.Writable<Atom.PullResult<A, E>, void>,
  options?: AtomStreamQueryOptions
)

  const items = computed(() =>
    Option.getOrElse(
      Option.map(AsyncResult.value(result.value), (_) => _.items),
      () => []
    )
  )
  const latest = computed(() => items.value.at(-1))
  const done = computed(() =>
    Option.getOrElse(
      Option.map(AsyncResult.value(result.value), (_) => _.done),
      () => false
    )
  )

  return {
    result,
    items,