Function unsafeCompleteDeferred

packages/effect/src/internal/pubsub.ts:1295–1297

(deferred: Deferred.Deferred<A>, a: A)

/** @internal */
const unsafeCompleteDeferred = <A>(deferred: Deferred.Deferred<A>, a: A): void => {
  core.deferredUnsafeDone(deferred, core.succeed(a))
}

/** @internal */
const unsafeOfferAll = <A>(queue: MutableQueue.MutableQueue<A>, as: Iterable<A>): Chunk.Chunk<A> => {