From d8b3e15bec60f58defad13e961f80354d250235d Mon Sep 17 00:00:00 2001
From: polwex <polwex@sortug.com>
Date: Sat, 14 Jun 2025 23:30:34 +0700
Subject: aaaaaa

---
 bs5/server/api/stream.ml | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)
 create mode 100644 bs5/server/api/stream.ml

(limited to 'bs5/server/api/stream.ml')

diff --git a/bs5/server/api/stream.ml b/bs5/server/api/stream.ml
new file mode 100644
index 0000000..8bfaa86
--- /dev/null
+++ b/bs5/server/api/stream.ml
@@ -0,0 +1,18 @@
+let streams =
+  [
+    Dream.post "/stream" (fun request ->
+        let request_stream = Dream.body_stream request in
+
+        Dream.stream
+          ~headers:[ ("Content-Type", "application/octet-stream") ]
+          (fun response_stream ->
+            let rec loop () =
+              match%lwt Dream.read request_stream with
+              | None -> Dream.close response_stream
+              | Some chunk ->
+                  let%lwt () = Dream.write response_stream chunk in
+                  let%lwt () = Dream.flush response_stream in
+                  loop ()
+            in
+            loop ()));
+  ]
-- 
cgit v1.2.3