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