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

Method offerAll

packages/effect/src/internal/mailbox.ts:138–151  ·  view source on GitHub ↗
(messages: Iterable<A>)

Source from the content-addressed store, hash-verified

136 return true
137 }
138 offerAll(messages: Iterable<A>): Effect<Chunk.Chunk<A>> {
139 return core.suspend(() => {
140 if (this.state._tag !== "Open") {
141 return core.succeed(Chunk.fromIterable(messages))
142 }
143 const remaining = this.unsafeOfferAllArray(messages)
144 if (remaining.length === 0) {
145 return exitEmpty
146 } else if (this.strategy === "dropping") {
147 return core.succeed(Chunk.unsafeFromArray(remaining))
148 }
149 return this.offerRemainingArray(remaining)
150 })
151 }
152 unsafeOfferAll(messages: Iterable<A>): Chunk.Chunk<A> {
153 return Chunk.unsafeFromArray(this.unsafeOfferAllArray(messages))
154 }

Callers

nothing calls this directly

Calls 2

unsafeOfferAllArrayMethod · 0.95
offerRemainingArrayMethod · 0.95

Tested by

no test coverage detected