Package org.infinispan.commons.reactive

Class RxJavaInterop

java.lang.Object
org.infinispan.commons.reactive.RxJavaInterop
Direct Known Subclasses:
RxJavaInterop
public class RxJavaInterop extends Object
Static factory class that provides methods to obtain commonly used instances for interoperation between RxJava and standard JRE.
Since:
10.0
Author:
wburns

  • Constructor Details

    • RxJavaInterop

      protected RxJavaInterop()

  • Method Details

    • entryToKeyFunction

      public static <K, V> io.reactivex.rxjava3.functions.Function<Map.Entry<K,V>,K> entryToKeyFunction()
      Provides a Function that can be used to convert from an instance of Map.Entry to the key of the entry. This is useful for the instance passed to a method like Flowable.map(Function).
      Type Parameters:
      K - key type
      V - value type
      Returns:
      rxjava function to convert from a Map.Entry to its key.

    • entryToValueFunction

      public static <K, V> io.reactivex.rxjava3.functions.Function<Map.Entry<K,V>,V> entryToValueFunction()
      Provides a Function that can be used to convert from an instance of Map.Entry to the value of the entry. This is useful for the instance passed to a method like Flowable.map(Function).
      Type Parameters:
      K - key type
      V - value type
      Returns:
      rxjava function to convert from a Map.Entry to its value.

    • cacheExceptionWrapper

      public static <R> io.reactivex.rxjava3.functions.Function<? super Throwable,org.reactivestreams.Publisher<R>> cacheExceptionWrapper()

    • identityFunction

      public static <R> io.reactivex.rxjava3.functions.Function<R,R> identityFunction()

    • emptyConsumer

      public static <R> io.reactivex.rxjava3.functions.Consumer<R> emptyConsumer()

    • completedFlowableProcessor

      public static <R> io.reactivex.rxjava3.processors.FlowableProcessor<R> completedFlowableProcessor()
      Returns a FlowableProcessor that is already complete and will ignore any value submitted to it and will immediately cancel any subscriptions it receives.
      Type Parameters:
      R - user value type
      Returns:
      processor that is completed

    • voidCompletionStageToFlowable

      public static <R> io.reactivex.rxjava3.core.Flowable<R> voidCompletionStageToFlowable(CompletionStage<?> stage)
      Transforms a void completable future into a flowable.

      The flowable completes without emitting any value.

      Type Parameters:
      R - : A generic type for the flowable.
      Parameters:
      stage - : Completable future to transform.
      Returns:
      A Flowable that completes once the completable future completes.