Module Lwt_queue

module Lwt_queue: sig .. end

type 'a t 

exception Timeout

val create : unit -> 'a t

val add : 'a -> 'a t -> unit

val take : ?timeout:float -> 'a t -> 'a Lwt.t