(_getRuntime: () => Context.Context<R>, getAtomRt: () => AtomClientRuntime)
| 529 | readonly live?: boolean | LiveQueryOptions |
| 530 | readonly invalidation?: QueryInvalidationMode |
| 531 | } |
| 532 | ): Atom.Atom<AsyncResult.AsyncResult<A, E>> => |
| 533 | withQueryOptions(atom, normalizeQueryOptions(options), queryKeyForAtom(atom)) |
| 534 | |
| 535 | const observedStreamAtom = <A, E>( |
| 536 | atom: Atom.Writable<Atom.PullResult<A, E>, void>, |
| 537 | options?: AtomStreamQueryOptions |
| 538 | ): Atom.Writable<Atom.PullResult<A, E>, void> => { |
| 539 | let next = atom |
| 540 | const refetchInterval = options?.refreshEvery ?? options?.refetchInterval |
| 541 | if (refetchInterval !== undefined) next = Atom.withRefresh(refetchInterval)(next) |
| 542 | const gcTime = options?.idleTTL ?? options?.gcTime |
| 543 | if (gcTime === "infinity") return Atom.keepAlive(next) |
| 544 | if (gcTime !== undefined) return Atom.setIdleTTL(next, gcTime) |
no outgoing calls
no test coverage detected
searching dependent graphs…