Commits

Anonymous committed fcdfc2c

Checkpoint. Test the convenience composers for the entity stream reactors.

Comments (0)

Files changed (1)

     let reactor k =
         let limits = { Iom_octet_stream.low = 256; high = 256 } in
         Iom_pipe.create ~limits k >>= fun (ijack, ojack) ->
-        Iom_layer.ingest ijack (new S.entity_scanner ~lim:256) >>= fun ijack ->
+        Mime_stream.scan_entity ~lim:256 ijack >>= fun ijack ->
         let top = new top ijack ojack in
         top#start
     
     let reactor k =
         let limits = { Iom_octet_stream.low = 256; high = 256 } in
         Iom_pipe.create ~limits k >>= fun (ijack, ojack) ->
-        Iom_layer.render ojack (new S.entity_emitter ~limits) >>= fun ojack ->
+        Mime_stream.emit_entity ~limits ojack >>= fun ojack ->
         let top = new top ijack ojack in
         top#start