Uses of Interface
com.forgerock.reactive.Consumer

Packages that use Consumer

Package	Description
com.forgerock.reactive	Provides asynchronous stream processing with non-blocking back pressure.

Uses of Consumer in com.forgerock.reactive

Methods in com.forgerock.reactive with parameters of type Consumer

Modifier and Type	Method	Description
Stream<V>	Stream.onError(Consumer<Throwable> onError)	Invokes the on error Consumer when an error occurs on this stream.
Stream<V>	Stream.onNext(Consumer<V> onNext)	Invokes the on next Consumer when this stream emits a value.
void	Completable.subscribe(Action completeAction, Consumer<Throwable> errorConsumer)	Subscribe to the result of this Completable.
void	Single.subscribe(Consumer<? super V> resultConsumer, Consumer<Throwable> errorConsumer)	Subscribe to the single value emitted by this Single.