(queue: MutableQueue.MutableQueue<A>, a: A)
| 731 | |
| 732 | /** @internal */ |
| 733 | export const unsafeRemove = <A>(queue: MutableQueue.MutableQueue<A>, a: A): void => { |
| 734 | unsafeOfferAll( |
| 735 | queue, |
| 736 | pipe(unsafePollAll(queue), Chunk.filter((b) => a !== b)) |
| 737 | ) |
| 738 | } |
| 739 | |
| 740 | /** @internal */ |
| 741 | export const unsafeCompleteTakers = <A>( |
no test coverage detected