Function withQueryOptions

packages/vue/src/atomQuery.ts:351–368

(
  self: Atom.Atom<AsyncResult.AsyncResult<A, E>>,
  opts: AtomQueryOptions = {}
)

// We only guarantee that a *genuine* new/parallel/future observer is never stuck on a departed
// observer's interrupt: per family atom we count live computes (`inFlight`), so "stuck" = a `waiting`
// result with `inFlight === 0` (nothing is actually fetching). On mount a stuck atom triggers one
// fresh fetch instead of adopting the dangling `waiting`; a genuinely in-flight fetch (`inFlight > 0`)
// is joined, not superseded (dedup / re-entrancy preserved). `recovering` dedupes concurrent mounts
// so exactly one recovery fetch is issued until a fetch is running again.
export interface QueryFetchState {
  inFlight: number
  recovering: boolean
}
export const queryFetchStates = new WeakMap<Atom.Atom<any>, QueryFetchState>()

const recoverStuckWaitingOnMount =
  <A, E>(familyAtom: Atom.Atom<AsyncResult.AsyncResult<A, E>>) =>
  (wrapped: Atom.Atom<AsyncResult.AsyncResult<A, E>>): Atom.Atom<AsyncResult.AsyncResult<A, E>> =>
    Atom.transform(wrapped, (get) => {
      const current = get.once(wrapped)
      get.subscribe(wrapped, (value) => get.setSelf(value))
      const state = queryFetchStates.get(familyAtom)
      const waiting = current?.waiting === true
      // Stuck: the result says `waiting` yet nothing is in-flight — an interrupt was hidden and left
      // `waiting` dangling. Treat it as not-yet-fetched and refetch; a live fetch (`inFlight > 0`) is
      // joined, not superseded. `recovering` prevents concurrent mounts from issuing more than one