(iterable: Iterable<A>, deferred: Deferred.Deferred<boolean>)
| 608 | } |
| 609 | |
| 610 | unsafeOffer(iterable: Iterable<A>, deferred: Deferred.Deferred<boolean>): void { |
| 611 | const stuff = Arr.fromIterable(iterable) |
| 612 | for (let i = 0; i < stuff.length; i++) { |
| 613 | const value = stuff[i] |
| 614 | if (i === stuff.length - 1) { |
| 615 | pipe(this.putters, MutableQueue.offer([value, deferred, true as boolean] as const)) |
| 616 | } else { |
| 617 | pipe(this.putters, MutableQueue.offer([value, deferred, false as boolean] as const)) |
| 618 | } |
| 619 | } |
| 620 | } |
| 621 | |
| 622 | unsafeRemove(deferred: Deferred.Deferred<boolean>): void { |
| 623 | unsafeOfferAll( |
no test coverage detected