(id: string, opts: { transport?: boolean; server?: boolean } = {})
| 291 | ignoreClose(id, "engine", engine ? () => Effect.runPromise(engine.shutdown) : undefined); |
| 292 | |
| 293 | const dispose = async (id: string, opts: { transport?: boolean; server?: boolean } = {}) => { |
| 294 | const transport = transports.get(id); |
| 295 | const server = servers.get(id); |
| 296 | const engine = engines.get(id); |
| 297 | transports.delete(id); |
| 298 | servers.delete(id); |
| 299 | owners.delete(id); |
| 300 | engines.delete(id); |
| 301 | lastSeen.delete(id); |
| 302 | activeRequests.delete(id); |
| 303 | if (opts.transport) |
| 304 | await ignoreClose(id, "transport", transport ? () => transport.close() : undefined); |
| 305 | if (opts.server) await ignoreClose(id, "server", server ? () => server.close() : undefined); |
| 306 | await shutdownEngine(id, engine); |
| 307 | }; |
| 308 | |
| 309 | /** |
| 310 | * Drive a transport for one web request, recovering any defect to a 500. On a |
no test coverage detected