Package org.infinispan.reactive

Class RxJavaInterop

java.lang.Object

org.infinispan.commons.reactive.RxJavaInterop

org.infinispan.reactive.RxJavaInterop

public class RxJavaInterop
extends RxJavaInterop

Static factory class that provides methods to obtain commonly used instances for interoperation between RxJava and standard JRE.

Since:

10.0

Author:

wburns

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.infinispan.util.logging.Log	log

Method Summary

Modifier and Type	Method	Description
static <R> io.reactivex.rxjava3.core.Flowable<R>	voidCompletionStageToFlowable(CompletionStage<Void> stage)
static <R> io.reactivex.rxjava3.core.Flowable<R>	voidCompletionStageToFlowable(CompletionStage<Void> stage, boolean ignoreErrorIfCancelled)	Same as voidCompletionStageToFlowable(CompletionStage) except that you can optionally have it so that if a throwable occurs in the stage that it isn't propagated if the returned Flowable's subscription was cancelled.

Methods inherited from class org.infinispan.commons.reactive.RxJavaInterop

cacheExceptionWrapper, emptyConsumer, entryToKeyFunction, entryToValueFunction, identityFunction

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected static final org.infinispan.util.logging.Log log

Method Detail

voidCompletionStageToFlowable

public static <R> io.reactivex.rxjava3.core.Flowable<R> voidCompletionStageToFlowable(CompletionStage<Void> stage)

voidCompletionStageToFlowable

public static <R> io.reactivex.rxjava3.core.Flowable<R> voidCompletionStageToFlowable(CompletionStage<Void> stage,
                                                                                      boolean ignoreErrorIfCancelled)

Same as voidCompletionStageToFlowable(CompletionStage) except that you can optionally have it so that if a throwable occurs in the stage that it isn't propagated if the returned Flowable's subscription was cancelled.

This method also only allows for a single subscriber to the Flowable, any additional subscribers will receive an exception when subscribing to the returned Flowable. voidCompletionStageToFlowable(CompletionStage) can support any number of subscribers.

Type Parameters:

R - stage type

Parameters:

stage - stage to complete

ignoreErrorIfCancelled - whether to ignore an error if cancelled

Returns:

a Flowable that is completed when the stage is