Module Pipe.Flushed

type t =
| Consumer of Consumer.t
| When_value_processed
| When_value_read
val sexp_of_t : t -> Ppx_sexp_conv_lib.Sexp.t