Module Lwt_queue

module Lwt_queue: sig .. end

Lwt-compatible blocking queue



type 'a t 
val create : unit -> 'a t
val is_empty : 'a t -> bool
val push : 'a t -> 'a -> unit
val pop : 'a t -> 'a Lwt.t
val clear : 'a t -> unit