Add Async_cstruct.Pipe to map pipes of Cstruct buffers to strings…

… or `Bigsubstring`

CHANGES

@@ -1,3 +1,6 @@
+0.7.1 (trunk):
+* Add `Async_cstruct.Pipe` to map pipes of `Cstruct` buffers to strings or `Bigsubstring`.
+
 0.7.0 (25-Feb-2013):
 
 * Add zero-copy conversion functions to/from the Core `Bigsubstring`.

async/async_cstruct.ml

@@ -35,3 +35,17 @@ let read rd t =
 let schedule_write wr t =
   let open Cstruct in
   Writer.schedule_bigstring ~pos:t.off ~len:t.len wr t.buffer
+
+module Pipe = struct
+  let map_string rd wr =
+    let rd = Pipe.map rd ~f:Cstruct.to_string in
+    let rd',wr' = Pipe.create () in
+    don't_wait_for (Pipe.transfer rd' wr ~f:Cstruct.of_string);
+    rd,wr'
+
+  let map_bigsubstring rd wr =
+    let rd = Pipe.map rd ~f:to_bigsubstring in
+    let rd',wr' = Pipe.create () in
+    don't_wait_for (Pipe.transfer rd' wr ~f:of_bigsubstring);
+    rd,wr'
+end

async/async_cstruct.mli

@@ -22,3 +22,15 @@ val of_bigsubstring : Bigsubstring.t -> Cstruct.t
 
 val read: Reader.t -> Cstruct.t -> int Reader.Read_result.t Deferred.t
 val schedule_write: Writer.t -> Cstruct.t -> unit
+
+module Pipe : sig
+  val map_string :
+    Cstruct.t Pipe.Reader.t ->
+    Cstruct.t Pipe.Writer.t ->
+    (string Pipe.Reader.t * string Pipe.Writer.t)
+
+  val map_bigsubstring :
+    Cstruct.t Pipe.Reader.t ->
+    Cstruct.t Pipe.Writer.t ->
+    (Bigsubstring.t Pipe.Reader.t * Bigsubstring.t Pipe.Writer.t)
+end