( resolver: RequestResolver<A>, entry: Request.Entry<A> )
| 174 | } |
| 175 | |
| 176 | const 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 | |
| 196 | const maybeRemoveEntry = <A extends Request.Any>( |
| 197 | resolver: RequestResolver<A>, |
no test coverage detected