async_kernel
Pipe.Flushed
async_kernel.eager_deferred
async_kernel.limiter_async
async_kernel.persistent_connection_kernel
async_kernel.weak_hashtbl_async
type t =
| Consumer of Consumer.t
| When_value_processed
| When_value_read
val sexp_of_t : t -> Ppx_sexp_conv_lib.Sexp.t