MCPcopy Create free account
hub / github.com/Effect-TS/effect / unsafeSize

Method unsafeSize

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

* Retrieves the size of the queue, which is equal to the number of elements * in the queue. This may be negative if fibers are suspended waiting for * elements to be added to the queue. Returns None if shutdown has been called

()

Source from the content-addressed store, hash-verified

210 * elements to be added to the queue. Returns None if shutdown has been called
211 */
212 unsafeSize(): Option.Option<number>
213
214 /**
215 * Returns `true` if the `Queue` contains at least one element, `false`

Callers 7

RpcServer.tsFile · 0.65
PubSub.test.tsFile · 0.65
unsafeSizeMethod · 0.65
unsafeSizeMethod · 0.65
Redis.tsFile · 0.65
Sharding.test.tsFile · 0.65

Implementers 5

QueueSpypackages/effect/test/Sink/constructors
SubscriptionImplpackages/effect/src/internal/pubsub.ts
PubSubImplpackages/effect/src/internal/pubsub.ts
QueueImplpackages/effect/src/internal/queue.ts
MapDequeuepackages/effect/src/internal/groupBy.t

Calls

no outgoing calls

Tested by 1

unsafeSizeMethod · 0.52