()
| 373 | |
| 374 | /** @internal */ |
| 375 | export const unbounded = <A>(): Effect.Effect<Queue.Queue<A>> => |
| 376 | pipe( |
| 377 | core.sync(() => MutableQueue.unbounded<A>()), |
| 378 | core.flatMap((queue) => make(backingQueueFromMutableQueue(queue), droppingStrategy())) |
| 379 | ) |
| 380 | |
| 381 | /** @internal */ |
| 382 | const unsafeMake = <A>( |
no test coverage detected