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 Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    RxJavaInterop()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static <R> io.reactivex.rxjava3.functions.Function<? super Throwable,org.reactivestreams.Publisher<R>>
    cacheExceptionWrapper()
     
    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.
    static <R> io.reactivex.rxjava3.functions.Consumer<R>
    emptyConsumer()
     
    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.
    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.
    static <R> io.reactivex.rxjava3.functions.Function<R,R>
    identityFunction()
     

    Methods inherited from class java.lang.Object

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

  • 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