See: Description
| Class | Description |
|---|---|
| Actions |
Helper class for Action interfaces.
|
| AsyncSubject<T> |
Represents the result (last value or exception) of an asynchronous operation
delivered through observation.
|
| Atomics |
Utility classes to perform some AtomicXYZ related operations
not supported by the classes themselves.
|
| CircularBuffer<T> |
A simple circular buffer with absolute indices.
|
| Closeables |
Utility methods for various closeable objects.
|
| ComparingHashMap<T,U> |
A hash map which uses custom equality comparer on its items.
|
| ComparingHashMap.Entry |
The set entry.
|
| ComparingHashSet<T> |
A hash set which uses custom equality comparer on its items.
|
| ComparingHashSet.Entry |
The set entry.
|
| CompositeCloseable |
A composite closeable which maintains a list of sub-closeables and has its
own alive state.
|
| DefaultCloseableObserver<T> |
Class to wrap a raw observer and provide it with
enforced event-sequence constraints and closeability.
|
| DefaultConnectableObservable<T,U> |
Default implementation of the connectable observable which can be disconnected
from its source independently from the registered observers.
|
| DefaultGroupedIterable<K,V> |
The default implementation for a grouped iterable
which holds the values in a
LinkedList. |
| DefaultGroupedObservable<Key,Value> |
A variant of the registering observable which stores a group key.
|
| DefaultObservable<T> |
An observable + observer implementation which keeps track of the registered observers and
common methods which dispatch events to all registered observers.
|
| DefaultObserver<T> |
The default implementation of the Observer interface
used by the Reactive operators.
|
| DefaultObserverEx<T> |
Extension to the default observer for cases when the observer itself
needs to track sub-observers and their close handlers.
|
| DefaultRunnable |
A default runnable implementation which may
use an internal or external lock to synchronize
access to its alternative onRun method.
|
| DefaultSink<T> |
A default sink implementation which wraps
an observer and closes a closeable on error
or finish.
|
| Func0Builder<T> |
Class holding a Func0 object and providing various relevant methods
of the
Functions utility class as instance methods. |
| Func1Builder<T,U> |
Class holding a Func1 object and providing various relevant methods
of the
Functions utility class as instance methods. |
| Func2Builder<T,U,V> |
Class holding a Func2 object and providing various relevant methods
of the
Functions utility class as instance methods. |
| Functions |
Helper class with function types.
|
| HybridSubject<T> |
A combination of the java and reactive observable and observer
classes and interfaces.
|
| Lambdas |
Utility class to create functions which have
their body as Javascript (or other script) language.
|
| LockedObserver<T> |
Class to wrap an observer's method calls via a lock to prevent
concurrent callback of its methods.
|
| Observables |
Utility class that helps in creating various observable instances.
|
| ObservableToIterableAdapter<T,U> |
Base class to help receive values from an observable sequence
through customizable iterator and observer.
|
| ObserverAdapter<T> |
A simple class that has empty implementations for all
observer methods.
|
| Observers |
Utility class that helps in creating various observer instances.
|
| ObserverToIteratorSink<T,U> |
Base class to help transition from reactive to interactive
world.
|
| OriginalObservableWrapper<T> |
Helper class that wraps a Java Observable and makes its
services availabel as java- and reactive- observable.
|
| OriginalObserverWrapper |
Wraps a java-observer and its associated helper observable.
|
| Producer<T> |
Base class to help implement various operators for observable sequences.
|
| Producer.State<U> |
The internal state of the observer registrations.
|
| R4JConfigManager |
The configuration manager for this library.
|
| ReactiveObservableWrapper<T> |
Wrapper for an existing reactive-observable and maps its
features to the java-observable.
|
| RefCountCloseable |
Represents a closeable resource that only allows closing
when all dependent closeable objects have been closed.
|
| RefCountCloseable.InnerCloseable |
The dependent closeable implementation.
|
| RefCountObservable<T> |
Observable which wraps an observable and manages a reference counting closeable.
|
| RunOnce |
Helper class which ensures that only a single action is invoked.
|
| SafeObserver<T> |
A simple wrapping observer which closes the specified
handle in case of error or finish message, or
an exception raised by the wrapped next.
|
| ScheduledCloseable |
A closeable instance which invokes the managed closeable's
close method on the given scheduler.
|
| Schedulers |
Utility class for schedulers, and manages
the global default scheduler.
|
| SequentialCloseable |
A closeable container which closes the previously managed
closeable if a new closeable is assigned to it.
|
| SingleCloseable |
Represents a closeable which allows only a single wrapped
closeable instance.
|
| SingleContainer<T> |
Helper class that stores a single element.
|
| SingleOption<T> |
Container that may contain a single value or an exception, but not both.
|
| Sink<T> |
Base class for implementing operators via lightweight sink that can be closed
to prevent events to flow to the wrapped observer.
|
| Subjects |
Utility class to wrap existing pairs of Observers and Observables under the Subject
interface.
|
| SynchronizedObserver<T> |
Class to wrap an observer's method calls via a synchronized to prevent
concurrent callback of its methods.
|
| TaggedCompositeCloseable |
A composite, modifyable holder of Closeable values with tag objects.
|
| Throwables |
Utility methods for handling exceptions and throwables.
|
| Unique<T> |
A single-element container that doesn't delegate
its equals and hashCode methods to the underlying value,
instead, it is equal only to itself and has a hashCode
as such.
|
| Annotation Type | Description |
|---|---|
| SuppressAnimalSniffer |
Suppress errors by the AnimalSniffer plugin.
|