public class RxJavaInterop extends Object
Modifier and Type | Method and Description |
---|---|
static <R> io.reactivex.rxjava3.functions.Function<? super Throwable,org.reactivestreams.Publisher<R>> |
cacheExceptionWrapper() |
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 <R> io.reactivex.rxjava3.functions.Function<R,R> |
identityFunction() |
public static <K,V> io.reactivex.rxjava3.functions.Function<Map.Entry<K,V>,K> entryToKeyFunction()
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)
.K
- key typeV
- value typepublic static <R> io.reactivex.rxjava3.functions.Function<? super Throwable,org.reactivestreams.Publisher<R>> cacheExceptionWrapper()
public static <R> io.reactivex.rxjava3.functions.Function<R,R> identityFunction()
public static <R> io.reactivex.rxjava3.functions.Consumer<R> emptyConsumer()
Copyright © 2021 JBoss by Red Hat. All rights reserved.