mirror of
https://github.com/anomalyco/opencode.git
synced 2026-11-08 01:07:06 +03:00
Aiden Cline
21 lines
784 B
TypeScript
21 lines
784 B
TypeScript
import { Effect } from "effect"
|
|
|
|
// Bounded by elapsed real time rather than attempts, so a busy machine still fits. Sleeps on a real timer, so it
|
|
// also works under TestClock.
|
|
export const eventually = <A, E, R>(
|
|
effect: Effect.Effect<A, E, R>,
|
|
predicate: (value: A) => boolean,
|
|
): Effect.Effect<A, E | Error, R> =>
|
|
Effect.gen(function* () {
|
|
const deadline = Date.now() + 10_000
|
|
while (true) {
|
|
const value = yield* effect
|
|
if (predicate(value)) return value
|
|
if (Date.now() > deadline) return yield* Effect.fail(new Error("Timed out waiting for value"))
|
|
yield* Effect.promise(() => Bun.sleep(1))
|
|
}
|
|
})
|
|
|
|
export const waitUntil = <E, R>(condition: Effect.Effect<boolean, E, R>) =>
|
|
eventually(condition, (ready) => ready).pipe(Effect.asVoid)
|