package apero-core

  1. Overview
  2. Docs
type 'a q = {
  1. stream : 'a Lwt_stream.t;
  2. bounded_push : 'a Lwt_stream.bounded_push;
  3. pusher : 'a -> unit Lwt.t;
}
val create : int -> 'a q
val push : 'a -> 'a q -> unit Lwt.t
val get : 'a q -> 'a option Lwt.t
val close : 'a q -> unit
val count : 'a q -> int
val blocked : 'a q -> bool
val closed : 'a q -> bool
OCaml

Innovation. Community. Security.