Function pollSchedule

packages/effect/test/TReentrantLock.test.ts:14–23

()

import * as TReentrantLock from "effect/TReentrantLock"

const pollSchedule = <E, A>(): Schedule.Schedule<Option.Option<Exit.Exit<E, A>>, Option.Option<Exit.Exit<E, A>>> =>
  pipe(
    Schedule.recurs(100),
    Schedule.zipRight(
      pipe(
        Schedule.identity<Option.Option<Exit.Exit<E, A>>>(),
        Schedule.whileOutput(Option.isNone)
      )
    )
  )

describe("TReentrantLock", () => {
  it.effect("one read lock", () =>