Commits

Dmitry Grebeniuk  committed 570d855

.

  • Participants
  • Parent commits e5bf662

Comments (0)

Files changed (1)

File dumbstreaming_it.ml

 module Make (I : IT_TYPE)
  :
   sig
+    (* None of EOF *)
+
     value read : (ntotal -> npart -> nbytes -> I.iteratee char 'i)
               -> I.iteratee 'i 'a
-              -> I.iteratee char 'a
+              -> I.iteratee char (option 'a)
     ;
   end
  =
     open It_add
     ;
 
+    value itpair_anyresult_lasterror it1 it2 =
+      itlist_anyresult_lasterror [it1; it2]
+    ;
 
-    value read _get_piece_iteratee _combine_pieces =
-      failwith "not implemented"
+    value read_packet get_piece_it combine_it =
+      .
+    ;
+
+
+
+    value read get_piece_it combine_it =
+      (some /* mapI */ read_packet get_piece_it combine_it)
+      /* itpair_anyresult_lasterror */
+      (read_eos >>= fun () -> None)
     ;
 
   end