Function waitForValue

packages/effect/test/Queue.test.ts:13–15

(ref: Effect.Effect<A>, value: A)

import { Array, Cause, Chunk, Deferred, Effect, Exit, Fiber, identity, pipe, Queue, Ref } from "effect"

export const waitForValue = <A>(ref: Effect.Effect<A>, value: A): Effect.Effect<A> => {
  return ref.pipe(Effect.zipLeft(Effect.yieldNow()), Effect.repeat({ until: (a) => value === a }))
}

export const waitForSize = <A>(queue: Queue.Queue<A>, size: number): Effect.Effect<number> => {
  return waitForValue(Queue.size(queue), size)