Function optionValue

packages/vue/src/query.ts:418–446

(
  arr: I | WatchSource<I> | undefined | WatchSource<Option.Option<I>>,
  options?: { readonly mode?: "optional"; readonly enabled?: MaybeRefOrGetter<boolean | undefined> }
)

      ] as const,
      {
        ...view,
        data
      }
    )
  })

  return Effect.runPromise(eff, { signal })
}

export type StreamQueryPullValue<A> = {
  readonly done: boolean
  readonly items: ReadonlyArray<A>
}

export interface StreamQueryView<A, E> {
  readonly result: ComputedRef<Atom.PullResult<A, E>>
  readonly items: ComputedRef<ReadonlyArray<A>>
  readonly latest: ComputedRef<A | undefined>
  readonly done: ComputedRef<boolean>
  readonly awaitResult: () => Effect.Effect<StreamQueryPullValue<A>, E | Cause.NoSuchElementError, never>
  readonly pull: () => void
  readonly pullAndAwait: () => Effect.Effect<StreamQueryPullValue<A>, E | Cause.NoSuchElementError, never>
  readonly refresh: () => void
  readonly registry: ReturnType<typeof injectRegistry>
  readonly atom: ComputedRef<Atom.Writable<Atom.PullResult<A, E>, void>>
}

export const useAtomStreamQuery = <A, E>(
  atom: () => Atom.Writable<Atom.PullResult<A, E>, void>
): StreamQueryView<A, E> => {
  const registry = injectRegistry()
  const atomRef = computed(atom)