MCPcopy Index your code
hub / github.com/Effect-TS/effect / unsafeOffer

Method unsafeOffer

packages/effect/src/internal/queue.ts:610–620  ·  view source on GitHub ↗
(iterable: Iterable<A>, deferred: Deferred.Deferred<boolean>)

Source from the content-addressed store, hash-verified

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(

Callers 1

handleSurplusMethod · 0.95

Calls 2

pipeFunction · 0.70
offerMethod · 0.65

Tested by

no test coverage detected