let pipe_iter () : unit Deferred.t = let r = Pipe.of_list (List.range 0 10) in Pipe.iter r ~f:(fun i -> return (printf "read %d\n" i))