sig type t val values_sent_downstream : Pipe.Consumer.t -> unit end