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

Method unsafeOpen

packages/effect/src/internal/effect/circular.ts:169–173  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

167 return this.unsafeSchedule(fiber)
168 })
169 unsafeOpen() {
170 if (this.isOpen) return
171 this.isOpen = true
172 this.flushWaiters()
173 }
174 release = core.withFiberRuntime<void>((fiber) => {
175 if (this.isOpen) {
176 return core.void

Callers 15

onReadableFunction · 0.80
onErrFunction · 0.80
onEndFunction · 0.80
_readMethod · 0.80
handleResponseFunction · 0.80
makeProtocolWorkerFunction · 0.80
sendFunction · 0.80
nextFunction · 0.80
PersistedQueue.tsFile · 0.80
Redis.tsFile · 0.80
Sharding.tsFile · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected