How to stream data in cohttp_eio server

[eWert-Online]

@talex5

Otherwise, respond will wait forever for more data (the switch doesn’t finish until it has finished).

But does the switch finish, when the client closes the connection, or are we leaking everything inside the daemon fiber in that case?

[talex5]

@talex5

let respond_stream ?headers ~status writer fn =
  Switch.run @@ fun sw ->
  let bw = Eio.Buf_write.create ~sw 4096 in
  Fiber.fork_daemon ~sw
    (fun () -> fn bw; Eio.Buf_write.close bw; `Stop_daemon);
  Cohttp_eio.Server.respond () ?headers ~status writer
    ~body:(source_of_buf_write bw)

@eWert-Online

But does the switch finish, when the client closes the connection, or are we leaking everything inside the daemon fiber in that case?

If Cohttp_eio.Server.respond finishes (either successfully or by raising an exception such as Connection_reset), the switch will cancel the daemon fiber and everything gets freed.

(but it looks to me like cohttp-eio will only notice that the connection is closed when doing a write, so it probably won’t notice until the next time the daemon fiber tries to send something)