aaaaaa

1 files changed, 18 insertions, 0 deletions

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 ()));
+  ]