Add Flow.load

Author: SGrondin

lib_eio/eio.ml

@@ -12,8 +12,13 @@ module Lazy = Lazy
 module Pool = Pool
 module Exn = Exn
 module Resource = Resource
-module Flow = Flow
 module Buf_read = Buf_read
+module Flow = struct
+  include Flow
+
+  let read_all flow =
+    Buf_read.(parse_exn take_all) flow ~max_size:max_int
+end
 module Buf_write = Buf_write
 module Net = Net
 module Process = Process

lib_eio/eio.mli

@@ -60,7 +60,12 @@ module Std = Std
 module Resource = Resource
 
 (** Byte streams. *)
-module Flow = Flow
+module Flow : sig
+  include module type of Flow
+
+  val read_all : _ source -> string
+  (** [read_all src] is a convenience wrapper to read an entire flow efficiently. *)
+end
 
 (** Buffered input and parsing *)
 module Buf_read = Buf_read

tests/buf_reader.md

@@ -241,7 +241,8 @@ Exception: End_of_file.
 
 ```ocaml
 # let bflow = R.of_flow mock_flow ~max_size:100 |> R.as_flow;;
-val bflow : Eio.Flow.source_ty Eio.Std.r = Eio__.Resource.T (<poly>, <abstr>)
+val bflow : Eio__Flow.source_ty Eio.Std.r =
+  Eio__.Resource.T (<poly>, <abstr>)
 # next := ["foo"; "bar"]; read bflow 2;;
 +mock_flow returning 3 bytes
 +Read "fo"

tests/flow.md

@@ -108,6 +108,22 @@ Copying from src using `Read_source_buffer`:
 - : unit = ()
 ```
 
+## read_all
+
+```ocaml
+# run @@ fun () ->
+  let each = String.init 256 Char.chr in
+  let data = List.init 40 (fun _ -> Cstruct.of_string each) in
+  let got = Eio.Flow.read_all (mock_source data) in
+  traceln "Input length: %d\nOutput length: %d\nEqual: %b"
+    (Cstruct.lenv data) (String.length got) (String.equal got (Cstruct.copyv data));
+  ;;
++Input length: 10240
++Output length: 10240
++Equal: true
+- : unit = ()
+```
+
 ## write
 
 ```ocaml