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
All Methods Static Methods Concrete Methods 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 asvoidCompletionStageToFlowable(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
-
-
-
-
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 asvoidCompletionStageToFlowable(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 completeignoreErrorIfCancelled
- whether to ignore an error if cancelled- Returns:
- a Flowable that is completed when the stage is
-
-