MCPcopy
hub / github.com/Effect-TS/effect / offerAll

Method offerAll

packages/effect/src/Queue.ts:130–130  ·  view source on GitHub ↗

* For Bounded Queue: uses the `BackPressure` Strategy, places the values in * the queue and always returns true. If the queue has reached capacity, then * the fiber performing the `offerAll` will be suspended until there is room * in the queue. * * For Unbounded Queue: Places all valu

(iterable: Iterable<A>)

Source from the content-addressed store, hash-verified

128 * queue but if there is no room it will not enqueue them and return false.
129 */
130 offerAll(iterable: Iterable<A>): Effect.Effect<boolean>
131}
132
133/**

Callers 15

makeStorageFunction · 0.65
inputTextFunction · 0.65
emitFunction · 0.65
LanguageModel.tsFile · 0.65
handleMessageFunction · 0.65
writeFunction · 0.65
Fiber.test.tsFile · 0.65
Queue.test.tsFile · 0.65
TQueue.test.tsFile · 0.65
Mailbox.test.tsFile · 0.65

Implementers 4

QueueSpypackages/effect/test/Sink/constructors
MailboxImplpackages/effect/src/internal/mailbox.t
PubSubImplpackages/effect/src/internal/pubsub.ts
QueueImplpackages/effect/src/internal/queue.ts

Calls

no outgoing calls

Tested by 1

offerAllMethod · 0.52