(state: ListenerState)
| 193 | } |
| 194 | |
| 195 | function forceClose(state: ListenerState) { |
| 196 | return Effect.all([state.http.closeAll, state.websockets.closeAll], { concurrency: "unbounded", discard: true }) |
| 197 | } |
| 198 | |
| 199 | function serverLayer(opts: { port: number; hostname: string }) { |
| 200 | const server = createServer() |