Package com.diffplug.common.rx

Interface Summary

Interface	Description
IObservable<T>	An object which can be supplied in an Observable form.
Rx.HasRxExecutor	Marker interface which allows an Executor to specify its own Scheduler.
RxBox<T>	RxGetter and Box combined in one: a value you can set, get, and subscribe to.
RxGetter<T>	Represents a value which can be accessed through a traditional get() method or by listening to its Observable.
RxSubscriber	An object which can subscribe observables to Rx listeners.
RxTracingPolicy	Plugin which gets notified of every call to Rx.subscribe, allowing various kinds of tracing.

Class Summary

Class	Description
Immutables	Methods for manipulating Guava's immutable collections.
RateProbe	A probe for inspecting rates in reactive systems.
Rx<T>	Unifies the listener models of RxJava's Observable with Guava's ListenableFuture , and also adds tracing capabilities.
Rx.RxExecutor	This class holds an instance of Executor (for ListenableFuture) and Scheduler (for Observable).
RxBiMap<K,V>	RxBox<ImmutableBiMap<T>> with convenience methods for creating and mutating the map.
RxBox.Default<T>	Standard implementation of an RxBox.
RxList<T>	RxBox<ImmutableList<T>> with convenience methods for creating and mutating the list.
RxMap<K,V>	RxBox<ImmutableMap<T>> with convenience methods for creating and mutating the map.
RxOptional<T>	RxBox<Optional<T>> with convenience methods for creating the optional.
RxOrderedSet<T>	RxBox<ImmutableList<T>> which promises to exclude duplicates.
RxSet<T>	RxBox<ImmutableSet<T>> with convenience methods for creating and mutating the set.
RxSortedMap<K,V>	RxBox<ImmutableSortedMap<T>> with convenience methods for creating and mutating the map.
RxSortedSet<T>	RxBox<ImmutableSortedSet<T>> with convenience methods for creating and mutating the set.
RxTracingPolicy.LogSubscriptionTrace	An RxTracingPolicy which logs the stack trace of every subscription, so that it can decorate any exceptions with the stack trace at the time they were subscribed.

Enum Summary

Enum	Description
RxOrderedSet.OnDuplicate	Policies for disallowing duplicates.