@Version(value="1.0.0")

Package uk.co.strangeskies.observable

Interface Summary

Interface	Description
Disposable
Observable<M>	Simple interface for an observable object, with methods to add and remove observers expecting the applicable type of message.
ObservableProperty<T>	A property which is observable as per ObservableValue, and whose value can also be set.
ObservableValue<T>	A value which can be fetched and observed for updates and changes.
ObservableValue.Change<T>	A value change event.
Observation
Observer<T>	An observer over one or more Observable instances.
OwnedMessage<O,M>
RequestAllocator

Class Summary

Class	Description
BackpressureReducingObserver<T,M>
ColdObservable<M>	A simple implementation of Observable which implements backpressure over the elements of an iterable.
DropWhileObserver<M>
ExecutorObserver<T>
FilteringObserver<M>
FlatMappingObserver<T,U>
HotObservable<M>	A simple implementation of Observable which maintains a list of listeners to receive events fired with HotObservable.next(Object).
ImmutableObservable<T>
ImmutableObservableValue<T>
MappingObserver<T,M>
MaterializingObserver<T>
MultiplePassthroughObserver<T>	This is a helper class for implementing passive observables.
ObservablePropertyImpl<T>	A simple implementation of ObservableProperty which maintains a list of listeners to receive change events fired with ObservablePropertyImpl.set(Object).
PassthroughObserver<T,U>	This is a helper class for implementing passive observables.
ReferenceObserver<M>
ReferenceOwnedObserver<O,M>
RepeatingObserver<T>
RequestCount
RetryingObserver<T>
SafeObserver<T>
SynchronizedObserver<M>
TakeWhileObserver<M>

Exception Summary

Exception	Description
AlreadyCompletedException
MissingValueException
UnexpectedMessageException