Commits

Anonymous committed 1949161

.

Comments (0)

Files changed (1)

dumbstreaming_it.ml

     ;
 
 
-
     value (read_data_lens :
       ~get_piece_it :
        ( ~ntotal:ntotal -> ~npart:npart -> ~nbytes:nbytes
       ~lens
      =
       let rec read_data_lens ~combine_it ~lens ~npart : I.iteratee char 'a =
-        let () = ignore ( combine_it : (I.iteratee 'i 'a) ) in
         match (lens, (combine_it : I.iteratee _ _)) with
-        [ ([], _) ->
+        [
+(*
+ ([], _) ->
            read_x0A >>= fun () ->
            I.joinI (I.return combine_it)
         | ([len :: lens], (I.IE_done _ | I.IE_cont (Some _) _)) ->
             I.drop len >>= fun () ->
             read_x0A >>= fun () ->
             read_data_lens ~combine_it ~lens ~npart:(npart + 1)
-        | ([len :: _lens], I.IE_done None k) ->
-            let this_piece_it = get_piece_it
+        |
+*)
+
+ ([len :: _lens], I.IE_cont None k) ->
+            let this_piece_it : I.iteratee char _ = get_piece_it
               ~ntotal ~npart ~nbytes:len in
-            (I.joinI & I.take len this_piece_it) >>= fun this_it_framed ->
-            this_it_framed >>= fun this_piece_res ->
+            (I.joinI & I.take len this_piece_it) >>= fun _this_it_framed ->
+            let () = ignore (_this_it_framed = ()) in
+
+(*
+            this_it_framed >>= fun (this_piece_res : _) ->
             read_x0A >>= fun () ->
 
             I.liftI (I.feedI k (I.chunk_of this_piece_res))
               >>= fun _combine_it ->
+*)
+
+ failwith "qq"
 (*
             read_data_lens ~combine_it ~lens ~npart:(npart + 1)
 *)
-failwith "qq"
+(*
+*)
         ]
       in
         read_data_lens ~combine_it ~npart:0 ~lens