summaryrefslogtreecommitdiff
path: root/bs5/server/api/stream.ml
diff options
context:
space:
mode:
Diffstat (limited to 'bs5/server/api/stream.ml')
-rw-r--r--bs5/server/api/stream.ml18
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 ()));
+ ]