Package-level declarations
Types
Creates a Connectable that delegates connection creation to effectHandlers and the corresponding Connections.
A Logger that delegates all logging to a list of provided loggers. Useful if you have different types of loggers that you would like to us simultaneously while maintaining single responsibility per logger implementation
Creates a Connectable that delegates to effectHandler and filters I values if the predicate returns true.
Creates a Connectable that delegates to effectHandler and maps the Effect and Events using mapEffect and mapEvent.
Collects events and passes them in order to a new consumer via dequeueAll.
An EventSource that can also consume events. If it has a subscriber, events will be immediately forwarded to that subscriber. If it doesn't have a subscriber, it will queue up events (up to the maximum capacity specified in the constructor), and forward all queued events to the next subscriber. Only a single subscription at a time is permitted.