(
iterable: Iterable<A>,
queue: Queue.BackingQueue<A>,
takers: MutableQueue.MutableQueue<Deferred.Deferred<A>>,
_isShutdown: MutableRef.MutableRef<boolean>
)
| 675 | } |
| 676 | |
| 677 | handleSurplus( |
| 678 | iterable: Iterable<A>, |
| 679 | queue: Queue.BackingQueue<A>, |
| 680 | takers: MutableQueue.MutableQueue<Deferred.Deferred<A>>, |
| 681 | _isShutdown: MutableRef.MutableRef<boolean> |
| 682 | ): Effect.Effect<boolean> { |
| 683 | return core.sync(() => { |
| 684 | this.unsafeOffer(queue, iterable) |
| 685 | unsafeCompleteTakers(this, queue, takers) |
| 686 | return true |
| 687 | }) |
| 688 | } |
| 689 | |
| 690 | unsafeOnQueueEmptySpace( |
| 691 | _queue: Queue.BackingQueue<A>, |
nothing calls this directly
no test coverage detected