Module Bounded_queue.Recv

Receiving side

type 'a t = {
  1. on_non_empty : (unit -> unit) -> unit;
    (*

    on_non_empty f registers f to be called whenever the queue transitions from empty to non-empty.

    *)
  2. try_pop : unit -> 'a pop_result;
    (*

    Try to pop an item right now.

    *)
  3. common : Common.t;
}
val try_pop : 'a t -> 'a pop_result
val on_non_empty : 'a t -> (unit -> unit) -> unit
val closed : 'a t -> bool
val num_discarded : 'a t -> int
val size : 'a t -> int
val high_watermark : 'a t -> int
val map : ('a -> 'b) -> 'a t -> 'b t