Function poll

packages/experimental/src/PersistedQueue/Redis.ts:240–250

(size: number)

      )

      const poll = (size: number) =>
        Effect.promise(() =>
          redis.take(
            queueKey,
            pendingKey,
            prefix,
            workerId,
            size,
            lockExpirationMillis
          )
        )

      yield* Effect.gen(function*() {
        while (true) {