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

Function removeEntryUnsafe

packages/effect/src/internal/request.ts:176–194  ·  view source on GitHub ↗
(
  resolver: RequestResolver<A>,
  entry: Request.Entry<A>
)

Source from the content-addressed store, hash-verified

174}
175
176const removeEntryUnsafe = <A extends Request.Any>(
177 resolver: RequestResolver<A>,
178 entry: Request.Entry<A>
179) => {
180 if (entry.uninterruptible) return
181 const batchMap = pendingBatches.get(resolver)
182 if (!batchMap) return
183 const key = resolver.batchKey(entry)
184 const batch = batchMap.get(key)
185 if (!batch) return
186
187 batch.entries.delete(entry)
188 batch.entrySet.delete(entry)
189
190 if (batch.entries.size === 0) {
191 batchMap.delete(key)
192 batch.fiber?.interruptUnsafe()
193 }
194}
195
196const maybeRemoveEntry = <A extends Request.Any>(
197 resolver: RequestResolver<A>,

Callers 2

requestUnsafeFunction · 0.85
maybeRemoveEntryFunction · 0.85

Calls 3

batchKeyMethod · 0.80
interruptUnsafeMethod · 0.80
getMethod · 0.65

Tested by

no test coverage detected