Class Functions
- java.lang.Object
-
- io.reactivex.rxjava3.internal.functions.Functions
-
public final class Functions extends java.lang.Object
Utility methods to convert the BiFunction, Function3..Function9 instances to Function of Object array.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
Functions.ActionConsumer<T>
(package private) static class
Functions.Array2Func<T1,T2,R>
(package private) static class
Functions.Array3Func<T1,T2,T3,R>
(package private) static class
Functions.Array4Func<T1,T2,T3,T4,R>
(package private) static class
Functions.Array5Func<T1,T2,T3,T4,T5,R>
(package private) static class
Functions.Array6Func<T1,T2,T3,T4,T5,T6,R>
(package private) static class
Functions.Array7Func<T1,T2,T3,T4,T5,T6,T7,R>
(package private) static class
Functions.Array8Func<T1,T2,T3,T4,T5,T6,T7,T8,R>
(package private) static class
Functions.Array9Func<T1,T2,T3,T4,T5,T6,T7,T8,T9,R>
(package private) static class
Functions.ArrayListCapacityCallable<T>
(package private) static class
Functions.BooleanSupplierPredicateReverse<T>
static class
Functions.BoundedConsumer
(package private) static class
Functions.CastToClass<T,U>
(package private) static class
Functions.ClassFilter<T,U>
(package private) static class
Functions.EmptyAction
(package private) static class
Functions.EmptyConsumer
(package private) static class
Functions.EmptyLongConsumer
(package private) static class
Functions.EmptyRunnable
(package private) static class
Functions.EqualsPredicate<T>
(package private) static class
Functions.ErrorConsumer
(package private) static class
Functions.FalsePredicate
(package private) static class
Functions.FutureAction
(package private) static class
Functions.HashSetSupplier
(package private) static class
Functions.Identity
(package private) static class
Functions.JustValue<T,U>
(package private) static class
Functions.ListSorter<T>
(package private) static class
Functions.MaxRequestSubscription
(package private) static class
Functions.NaturalComparator
(package private) static class
Functions.NotificationOnComplete<T>
(package private) static class
Functions.NotificationOnError<T>
(package private) static class
Functions.NotificationOnNext<T>
(package private) static class
Functions.NullProvider
(package private) static class
Functions.OnErrorMissingConsumer
(package private) static class
Functions.TimestampFunction<T>
(package private) static class
Functions.ToMapKeySelector<K,T>
(package private) static class
Functions.ToMapKeyValueSelector<K,V,T>
(package private) static class
Functions.ToMultimapKeyValueSelector<K,V,T>
(package private) static class
Functions.TruePredicate
-
Field Summary
Fields Modifier and Type Field Description (package private) static Predicate<java.lang.Object>
ALWAYS_FALSE
(package private) static Predicate<java.lang.Object>
ALWAYS_TRUE
static Action
EMPTY_ACTION
(package private) static Consumer<java.lang.Object>
EMPTY_CONSUMER
static LongConsumer
EMPTY_LONG_CONSUMER
static java.lang.Runnable
EMPTY_RUNNABLE
static Consumer<java.lang.Throwable>
ERROR_CONSUMER
(package private) static Function<java.lang.Object,java.lang.Object>
IDENTITY
A singleton identity function.(package private) static Supplier<java.lang.Object>
NULL_SUPPLIER
static Consumer<java.lang.Throwable>
ON_ERROR_MISSING
Wraps the consumed Throwable into an OnErrorNotImplementedException and signals it to the plugin error handler.static Consumer<org.reactivestreams.Subscription>
REQUEST_MAX
-
Constructor Summary
Constructors Modifier Constructor Description private
Functions()
Utility class.
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> Consumer<T>
actionConsumer(Action action)
static <T> @NonNull Predicate<T>
alwaysFalse()
static <T> @NonNull Predicate<T>
alwaysTrue()
static <T> Consumer<T>
boundedConsumer(int bufferSize)
static <T,U>
@NonNull Function<T,U>castFunction(@NonNull java.lang.Class<U> target)
Returns a function that cast the incoming values via a Class object.static <T> Supplier<java.util.List<T>>
createArrayList(int capacity)
static <T> Supplier<java.util.Set<T>>
createHashSet()
static <T> Consumer<T>
emptyConsumer()
Returns an empty consumer that does nothing.static <T> Predicate<T>
equalsWith(T value)
static @NonNull Action
futureAction(@NonNull java.util.concurrent.Future<?> future)
Wraps the blocking get call of the Future into an Action.static <T> @NonNull Function<T,T>
identity()
Returns an identity function that simply returns its argument.static <T,U>
Predicate<T>isInstanceOf(java.lang.Class<U> clazz)
static <T> @NonNull java.util.concurrent.Callable<T>
justCallable(T value)
Returns a Callable that returns the given value.static <T,U>
@NonNull Function<T,U>justFunction(U value)
Returns a Function that ignores its parameter and returns the given value.static <T> @NonNull Supplier<T>
justSupplier(T value)
Returns a Supplier that returns the given value.static <T> Function<java.util.List<T>,java.util.List<T>>
listSorter(java.util.Comparator<? super T> comparator)
static <T> java.util.Comparator<T>
naturalComparator()
static <T> Action
notificationOnComplete(Consumer<? super Notification<T>> onNotification)
static <T> Consumer<java.lang.Throwable>
notificationOnError(Consumer<? super Notification<T>> onNotification)
static <T> Consumer<T>
notificationOnNext(Consumer<? super Notification<T>> onNotification)
static <T> @NonNull Supplier<T>
nullSupplier()
static <T> Predicate<T>
predicateReverseFor(BooleanSupplier supplier)
static <T> Function<T,Timed<T>>
timestampWith(java.util.concurrent.TimeUnit unit, Scheduler scheduler)
static <T1,T2,R>
@NonNull Function<java.lang.Object[],R>toFunction(@NonNull BiFunction<? super T1,? super T2,? extends R> f)
static <T1,T2,T3,R>
@NonNull Function<java.lang.Object[],R>toFunction(@NonNull Function3<T1,T2,T3,R> f)
static <T1,T2,T3,T4,R>
@NonNull Function<java.lang.Object[],R>toFunction(@NonNull Function4<T1,T2,T3,T4,R> f)
static <T1,T2,T3,T4,T5,R>
@NonNull Function<java.lang.Object[],R>toFunction(@NonNull Function5<T1,T2,T3,T4,T5,R> f)
static <T1,T2,T3,T4,T5,T6,R>
@NonNull Function<java.lang.Object[],R>toFunction(@NonNull Function6<T1,T2,T3,T4,T5,T6,R> f)
static <T1,T2,T3,T4,T5,T6,T7,R>
@NonNull Function<java.lang.Object[],R>toFunction(@NonNull Function7<T1,T2,T3,T4,T5,T6,T7,R> f)
static <T1,T2,T3,T4,T5,T6,T7,T8,R>
@NonNull Function<java.lang.Object[],R>toFunction(@NonNull Function8<T1,T2,T3,T4,T5,T6,T7,T8,R> f)
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R>
@NonNull Function<java.lang.Object[],R>toFunction(@NonNull Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,R> f)
static <T,K>
BiConsumer<java.util.Map<K,T>,T>toMapKeySelector(Function<? super T,? extends K> keySelector)
static <T,K,V>
BiConsumer<java.util.Map<K,V>,T>toMapKeyValueSelector(Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector)
static <T,K,V>
BiConsumer<java.util.Map<K,java.util.Collection<V>>,T>toMultimapKeyValueSelector(Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector, Function<? super K,? extends java.util.Collection<? super V>> collectionFactory)
-
-
-
Field Detail
-
IDENTITY
static final Function<java.lang.Object,java.lang.Object> IDENTITY
A singleton identity function.
-
EMPTY_RUNNABLE
public static final java.lang.Runnable EMPTY_RUNNABLE
-
EMPTY_ACTION
public static final Action EMPTY_ACTION
-
EMPTY_CONSUMER
static final Consumer<java.lang.Object> EMPTY_CONSUMER
-
ERROR_CONSUMER
public static final Consumer<java.lang.Throwable> ERROR_CONSUMER
-
ON_ERROR_MISSING
public static final Consumer<java.lang.Throwable> ON_ERROR_MISSING
Wraps the consumed Throwable into an OnErrorNotImplementedException and signals it to the plugin error handler.
-
EMPTY_LONG_CONSUMER
public static final LongConsumer EMPTY_LONG_CONSUMER
-
ALWAYS_TRUE
static final Predicate<java.lang.Object> ALWAYS_TRUE
-
ALWAYS_FALSE
static final Predicate<java.lang.Object> ALWAYS_FALSE
-
NULL_SUPPLIER
static final Supplier<java.lang.Object> NULL_SUPPLIER
-
REQUEST_MAX
public static final Consumer<org.reactivestreams.Subscription> REQUEST_MAX
-
-
Method Detail
-
toFunction
@NonNull public static <T1,T2,R> @NonNull Function<java.lang.Object[],R> toFunction(@NonNull @NonNull BiFunction<? super T1,? super T2,? extends R> f)
-
toFunction
@NonNull public static <T1,T2,T3,R> @NonNull Function<java.lang.Object[],R> toFunction(@NonNull @NonNull Function3<T1,T2,T3,R> f)
-
toFunction
@NonNull public static <T1,T2,T3,T4,R> @NonNull Function<java.lang.Object[],R> toFunction(@NonNull @NonNull Function4<T1,T2,T3,T4,R> f)
-
toFunction
@NonNull public static <T1,T2,T3,T4,T5,R> @NonNull Function<java.lang.Object[],R> toFunction(@NonNull @NonNull Function5<T1,T2,T3,T4,T5,R> f)
-
toFunction
@NonNull public static <T1,T2,T3,T4,T5,T6,R> @NonNull Function<java.lang.Object[],R> toFunction(@NonNull @NonNull Function6<T1,T2,T3,T4,T5,T6,R> f)
-
toFunction
@NonNull public static <T1,T2,T3,T4,T5,T6,T7,R> @NonNull Function<java.lang.Object[],R> toFunction(@NonNull @NonNull Function7<T1,T2,T3,T4,T5,T6,T7,R> f)
-
toFunction
@NonNull public static <T1,T2,T3,T4,T5,T6,T7,T8,R> @NonNull Function<java.lang.Object[],R> toFunction(@NonNull @NonNull Function8<T1,T2,T3,T4,T5,T6,T7,T8,R> f)
-
toFunction
@NonNull public static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> @NonNull Function<java.lang.Object[],R> toFunction(@NonNull @NonNull Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,R> f)
-
identity
@NonNull public static <T> @NonNull Function<T,T> identity()
Returns an identity function that simply returns its argument.- Type Parameters:
T
- the input and output value type- Returns:
- the identity function
-
emptyConsumer
public static <T> Consumer<T> emptyConsumer()
Returns an empty consumer that does nothing.- Type Parameters:
T
- the consumed value type, the value is ignored- Returns:
- an empty consumer that does nothing.
-
futureAction
@NonNull public static @NonNull Action futureAction(@NonNull @NonNull java.util.concurrent.Future<?> future)
Wraps the blocking get call of the Future into an Action.- Parameters:
future
- the future to call get() on, not null- Returns:
- the new Action instance
-
justCallable
@NonNull public static <T> @NonNull java.util.concurrent.Callable<T> justCallable(@NonNull T value)
Returns a Callable that returns the given value.- Type Parameters:
T
- the value type- Parameters:
value
- the value to return- Returns:
- the new Callable instance
-
justSupplier
@NonNull public static <T> @NonNull Supplier<T> justSupplier(@NonNull T value)
Returns a Supplier that returns the given value.- Type Parameters:
T
- the value type- Parameters:
value
- the value to return- Returns:
- the new Callable instance
-
justFunction
@NonNull public static <T,U> @NonNull Function<T,U> justFunction(@NonNull U value)
Returns a Function that ignores its parameter and returns the given value.- Type Parameters:
T
- the function's input typeU
- the value and return type of the function- Parameters:
value
- the value to return- Returns:
- the new Function instance
-
castFunction
@NonNull public static <T,U> @NonNull Function<T,U> castFunction(@NonNull @NonNull java.lang.Class<U> target)
Returns a function that cast the incoming values via a Class object.- Type Parameters:
T
- the input value typeU
- the output and target type- Parameters:
target
- the target class- Returns:
- the new Function instance
-
createArrayList
public static <T> Supplier<java.util.List<T>> createArrayList(int capacity)
-
equalsWith
public static <T> Predicate<T> equalsWith(T value)
-
createHashSet
public static <T> Supplier<java.util.Set<T>> createHashSet()
-
notificationOnNext
public static <T> Consumer<T> notificationOnNext(Consumer<? super Notification<T>> onNotification)
-
notificationOnError
public static <T> Consumer<java.lang.Throwable> notificationOnError(Consumer<? super Notification<T>> onNotification)
-
notificationOnComplete
public static <T> Action notificationOnComplete(Consumer<? super Notification<T>> onNotification)
-
isInstanceOf
public static <T,U> Predicate<T> isInstanceOf(java.lang.Class<U> clazz)
-
predicateReverseFor
public static <T> Predicate<T> predicateReverseFor(BooleanSupplier supplier)
-
timestampWith
public static <T> Function<T,Timed<T>> timestampWith(java.util.concurrent.TimeUnit unit, Scheduler scheduler)
-
toMapKeySelector
public static <T,K> BiConsumer<java.util.Map<K,T>,T> toMapKeySelector(Function<? super T,? extends K> keySelector)
-
toMapKeyValueSelector
public static <T,K,V> BiConsumer<java.util.Map<K,V>,T> toMapKeyValueSelector(Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector)
-
toMultimapKeyValueSelector
public static <T,K,V> BiConsumer<java.util.Map<K,java.util.Collection<V>>,T> toMultimapKeyValueSelector(Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector, Function<? super K,? extends java.util.Collection<? super V>> collectionFactory)
-
naturalComparator
public static <T> java.util.Comparator<T> naturalComparator()
-
listSorter
public static <T> Function<java.util.List<T>,java.util.List<T>> listSorter(java.util.Comparator<? super T> comparator)
-
boundedConsumer
public static <T> Consumer<T> boundedConsumer(int bufferSize)
-
-