Function serve

packages/platform-bun/src/internal/httpServer.ts:74–108

(httpApp, middleware)

    return Server.make({
      address: { _tag: "TcpAddress", port: server.port!, hostname: server.hostname! },
      serve(httpApp, middleware) {
        return Effect.gen(function*() {
          const runFork = yield* FiberSet.makeRuntime<never>()
          const runtime = yield* Effect.runtime<never>()
          const app = App.toHandled(httpApp, (request, response) =>
            Effect.sync(() => {
              ;(request as ServerRequestImpl).resolve(makeResponse(request, response, runtime))
            }), middleware)

          function handler(request: Request, server: BunServer) {
            return new Promise<Response>((resolve, _reject) => {
              const fiber = runFork(Effect.provideService(
                app,
                ServerRequest.HttpServerRequest,
                new ServerRequestImpl(request, resolve, removeHost(request.url), server)
              ))
              request.signal.addEventListener("abort", () => {
                runFork(fiber.interruptAsFork(Error.clientAbortFiberId))
              }, { once: true })
            })
          }

          yield* Effect.acquireRelease(
            Effect.sync(() => {
              handlerStack.push(handler)
              server.reload({ fetch: handler })
            }),
            () =>
              Effect.sync(() => {
                handlerStack.pop()
                server.reload({ fetch: handlerStack[handlerStack.length - 1] })
              })
          )
        })
      }
    })
  })