lwt: write_frame: flush output after write (fix #132)

vbmithr · Jan 2, 2023 · 3edc21a · 3edc21a
1 parent 8fcfc56
commit 3edc21a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lwt/websocket_lwt_unix.ml b/lwt/websocket_lwt_unix.ml
@@ -117,7 +117,8 @@ let connect ?(extra_headers = Cohttp.Header.init ())
     Lwt.wrap2 (write_frame_to_buf ~mode:(Client random_string)) buf frame
     >>= fun () ->
     Lwt.catch
-      (fun () -> Lwt_io.write oc (Buffer.contents buf))
+      (fun () ->
+        Lwt_io.write oc (Buffer.contents buf) >>= fun () -> Lwt_io.flush oc)
       (fun exn ->
         Lwt.async (fun () -> Lwt_io.close oc);
         Lwt.fail exn)