Class 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 Detail

      • RxJavaInterop

        protected RxJavaInterop()
    • Method Detail

      • 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()