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

Method releaseUnsafe

packages/effect/src/Semaphore.ts:257–268  ·  view source on GitHub ↗
(fiber: Fiber<any, any>, n: number)

Source from the content-addressed store, hash-verified

255 }
256
257 releaseUnsafe(fiber: Fiber<any, any>, n: number): number {
258 this.taken -= n
259 if (this.waiters.size > 0) {
260 fiber.currentDispatcher.scheduleTask(() => {
261 for (const observer of this.waiters) {
262 if (this.free <= 0) break
263 observer()
264 }
265 }, 0)
266 }
267 return this.free
268 }
269
270 resize(permits: number) {
271 return core.withFiber((fiber) => {

Callers 5

resizeMethod · 0.95
releaseMethod · 0.95
releaseAllMethod · 0.95
withPermitsMethod · 0.95

Calls 2

observerFunction · 0.85
scheduleTaskMethod · 0.65

Tested by

no test coverage detected