Package com.forgerock.reactive

Provides asynchronous stream processing with non-blocking back pressure.

Interface Summary

Interface	Description
Action	A functional interface similar to Runnable but allows throwing a checked exception.
Completable	Completable is used to communicates a terminated operation which doesn't produce a result.
Completable.Emitter	Adapts the streaming api to a callback one.
Completable.Subscriber	Subscriber is notified when the operation has been completed, successfully or not.
Consumer<V>	A functional interface (callback) that consumes a single value.
ReactiveHandler<C,I,O>	Handle the processing of an input in a given context and return the resulting output.
Single<V>	Single is a reactive-streams compatible promise.
Single.Emitter<V>	Adapts the streaming api to a callback one.
Single.Subscriber<V>	Subscriber is notified when the operation has been completed, successfully or not.
Stream<V>	Stream is a reactive-streams compliant way to chain operations and transformation on a stream of data.

Class Summary

Class	Description
ReactiveFilter<C,I1,O1,I2,O2>	Filters and/or transforms the request and/or response of an exchange.
ReactiveFilter.SimpleReactiveFilter<C,I,O>	A simple ReactiveHandler performing simple filtering without type transformation.
RxJavaStreams	Stream and Single implementations based on RxJava.
ServerConnectionFactoryAdapter	Deprecated.
ServerConnectionFactoryAdapter.ServerConnectionAdapter	Adapt a ServerConnection to a Function compatible with TransportProvider.getLDAPListener(java.util.Set, Function, org.forgerock.util.Options).