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))