sig
module Debug :
functor
(Bus : sig
type 'a t
val invariant :
'a Core_kernel.Invariant_intf.inv ->
'a t Core_kernel.Invariant_intf.inv
val create : can_subscribe_after_start:bool -> 'a t
val start : 'a t -> unit
val flushed : 'a t -> unit Import.Deferred.t
val write : 'a t -> 'a -> unit
module Subscriber :
sig
type 'a t
val sexp_of_t :
('a -> Sexplib.Sexp.t) -> 'a t -> Sexplib.Sexp.t
end
val subscribe_exn : 'a t -> f:('a -> unit) -> 'a Subscriber.t
val unsubscribe : 'a t -> 'a Subscriber.t -> unit
val reader_exn : 'a t -> 'a Import.Pipe.Reader.t
val sexp_of_t :
('a -> Sexplib.Sexp.t) -> 'a t -> Sexplib.Sexp.t
end) ->
sig
type 'a t = 'a Bus.t
val invariant :
'a Core_kernel.Invariant_intf.inv ->
'a t Core_kernel.Invariant_intf.inv
val create : can_subscribe_after_start:bool -> 'a t
val start : 'a t -> unit
val flushed : 'a t -> unit Import.Deferred.t
val write : 'a t -> 'a -> unit
module Subscriber :
sig
type 'a t = 'a Bus.Subscriber.t
val sexp_of_t : ('a -> Sexplib.Sexp.t) -> 'a t -> Sexplib.Sexp.t
end
val subscribe_exn : 'a t -> f:('a -> unit) -> 'a Subscriber.t
val unsubscribe : 'a t -> 'a Subscriber.t -> unit
val reader_exn : 'a t -> 'a Import.Pipe.Reader.t
val sexp_of_t : ('a -> Sexplib.Sexp.t) -> 'a t -> Sexplib.Sexp.t
val check_invariant : bool Pervasives.ref
val show_messages : bool Pervasives.ref
end
end