Function unsafeRemove

packages/effect/src/internal/pubsub.ts:1325–1330

(queue: MutableQueue.MutableQueue<A>, value: A)

/** @internal */
const unsafeRemove = <A>(queue: MutableQueue.MutableQueue<A>, value: A): void => {
  unsafeOfferAll(
    queue,
    pipe(unsafePollAllQueue(queue), Chunk.filter((elem) => elem !== value))
  )
}

// -----------------------------------------------------------------------------
// PubSub.Strategy