(self: Dequeue<A, E>)
| 1418 | * @since 2.0.0 |
| 1419 | */ |
| 1420 | export const take = <A, E>(self: Dequeue<A, E>): Effect<A, E> => |
| 1421 | internalEffect.suspend( |
| 1422 | () => takeUnsafe(self) ?? internalEffect.andThen(awaitTake(self), take(self)) |
| 1423 | ) |
| 1424 | |
| 1425 | /** |
| 1426 | * Attempts to take one item from the queue without waiting. |
nothing calls this directly
no test coverage detected