(deferred: Deferred.Deferred<boolean>)
| 1501 | } |
| 1502 | |
| 1503 | unsafeRemove(deferred: Deferred.Deferred<boolean>): void { |
| 1504 | unsafeOfferAll( |
| 1505 | this.publishers, |
| 1506 | pipe(unsafePollAllQueue(this.publishers), Chunk.filter(([_, a]) => a !== deferred)) |
| 1507 | ) |
| 1508 | } |
| 1509 | } |
| 1510 | |
| 1511 | /** |
no test coverage detected