Legend:
Library
Module
Module type
Parameter
Class
Class type
Library
Module
Module type
Parameter
Class
Class type
package lwt-watcher
This module implements a one-to-many publish/suscribe pattern.
Clients can register/unregister to an input. Events notified to the input (through notify) are dispatched asynchronously to all registered clients through an Lwt_stream. A client receives only events sent after registration and before unregistration.
val create_input : unit -> 'a inputval notify : 'a input -> 'a -> unitnotify t v publishes value v to the input t
val create_stream : 'a input -> 'a Lwt_stream.t * stoppercreate_stream t registers a new client which can read published values via a stream. A stopper is used to shutdown the client.
val create_fake_stream : unit -> 'a Lwt_stream.t * stopperA fake stream never receives any value.
val shutdown : stopper -> unitshutdown s unregisters the client associated to s. None is pushed to the stream.
val shutdown_input : 'a input -> unitShutdowns all the clients of this input