()
| 363 | } |
| 364 | |
| 365 | get take(): Effect.Effect<B> { |
| 366 | return pipe(Queue.take(this.dequeue), Effect.map((a) => this.f(a))) |
| 367 | } |
| 368 | |
| 369 | get takeAll(): Effect.Effect<Chunk.Chunk<B>> { |
| 370 | return pipe(Queue.takeAll(this.dequeue), Effect.map(Chunk.map((a) => this.f(a)))) |