Package org.forgerock.openig.reactive

Contains RxJava specific tools.

Class Summary

Class	Description
CharBufferToLineFlowableTransformer	Transforms a Flowable of CharBuffer into a Flowable of String, by splitting on EOL chars ('\r' and '\n').
MdcAwareSingleObserver<T>	A SingleObserver wrapper that manages the MDC.
ReactiveUtils	Utility class for ReactiveX operations.