Module Lwt_watcherSource

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.

Sourcetype 'a input
Sourceval create_input : unit -> 'a input
Sourceval notify : 'a input -> 'a -> unit

notify t v publishes value v to the input t

Sourcetype stopper
Sourceval create_stream : 'a input -> 'a Lwt_stream.t * stopper

create_stream t registers a new client which can read published values via a stream. A stopper is used to shutdown the client.

Sourceval create_fake_stream : unit -> 'a Lwt_stream.t * stopper

A fake stream never receives any value.

Sourceval shutdown : stopper -> unit

shutdown s unregisters the client associated to s. None is pushed to the stream.

Sourceval shutdown_input : 'a input -> unit

Shutdowns all the clients of this input