Class Functions

java.lang.Object

io.reactivex.rxjava3.internal.functions.Functions

public final class Functions
extends 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
static class	Functions.BoundedConsumer

Field Summary

Fields

Modifier and Type	Field	Description
static final Action	EMPTY_ACTION
static final LongConsumer	EMPTY_LONG_CONSUMER
static final Runnable	EMPTY_RUNNABLE
static final Consumer<Throwable>	ERROR_CONSUMER
static final Consumer<Throwable>	ON_ERROR_MISSING	Wraps the consumed Throwable into an OnErrorNotImplementedException and signals it to the plugin error handler.
static final Consumer<org.reactivestreams.Subscription>	REQUEST_MAX

Method Summary

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 Class<U> target)	Returns a function that cast the incoming values via a Class object.
static <T> Supplier<List<T>>	createArrayList(int capacity)
static <T> Supplier<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 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(Class<U> clazz)
static <T> @NonNull 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<List<T>,List<T>>	listSorter(Comparator<? super T> comparator)
static <T> Comparator<T>	naturalComparator()
static <T> Action	notificationOnComplete(Consumer<? super Notification<T>> onNotification)
static <T> Consumer<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(TimeUnit unit, Scheduler scheduler)
static <T1,T2,R> @NonNull Function<Object[],R>	toFunction(@NonNull BiFunction<? super T1, ? super T2, ? extends R> f)
static <T1,T2,T3,R> @NonNull Function<Object[],R>	toFunction(@NonNull Function3<T1,T2,T3,R> f)
static <T1,T2,T3,T4,R> @NonNull Function<Object[],R>	toFunction(@NonNull Function4<T1,T2,T3,T4,R> f)
static <T1,T2,T3,T4,T5,R> @NonNull Function<Object[],R>	toFunction(@NonNull Function5<T1,T2,T3,T4,T5,R> f)
static <T1,T2,T3,T4,T5,T6,R> @NonNull Function<Object[],R>	toFunction(@NonNull Function6<T1,T2,T3,T4,T5,T6,R> f)
static <T1,T2,T3,T4,T5,T6,T7,R> @NonNull Function<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<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<Object[],R>	toFunction(@NonNull Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,R> f)
static <T,K> BiConsumer<Map<K,T>,T>	toMapKeySelector(Function<? super T, ? extends K> keySelector)
static <T,K,V> BiConsumer<Map<K,V>,T>	toMapKeyValueSelector(Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector)
static <T,K,V> BiConsumer<Map<K, Collection<V>>, T>	toMultimapKeyValueSelector(Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, Function<? super K, ? extends Collection<? super V>> collectionFactory)

Methods inherited from class Object

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

Field Details

EMPTY_RUNNABLE

public static final Runnable EMPTY_RUNNABLE

EMPTY_ACTION

public static final Action EMPTY_ACTION

ERROR_CONSUMER

public static final Consumer<Throwable> ERROR_CONSUMER

ON_ERROR_MISSING

public static final Consumer<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

REQUEST_MAX

public static final Consumer<org.reactivestreams.Subscription> REQUEST_MAX

Method Details

toFunction

@NonNull
public static <T1,T2,R>
@NonNull Function<Object[],R> toFunction(@NonNull
 @NonNull BiFunction<? super T1, ? super T2, ? extends R> f)

toFunction

@NonNull
public static <T1,T2,T3,R>
@NonNull Function<Object[],R> toFunction(@NonNull
 @NonNull Function3<T1,T2,T3,R> f)

toFunction

@NonNull
public static <T1,T2,T3,T4,R>
@NonNull Function<Object[],R> toFunction(@NonNull
 @NonNull Function4<T1,T2,T3,T4,R> f)

toFunction

@NonNull
public static <T1,T2,T3,T4,T5,R>
@NonNull Function<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<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<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<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<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.

alwaysTrue

@NonNull
public static <T> @NonNull Predicate<T> alwaysTrue()

alwaysFalse

@NonNull
public static <T> @NonNull Predicate<T> alwaysFalse()

nullSupplier

@NonNull
public static <T> @NonNull Supplier<T> nullSupplier()

futureAction

@NonNull
public static @NonNull Action futureAction(@NonNull
 @NonNull 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 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 type

U - 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 Class<U> target)

Returns a function that cast the incoming values via a Class object.

Type Parameters:

T - the input value type

U - the output and target type

Parameters:

target - the target class

Returns:

the new Function instance

createArrayList

public static <T> Supplier<List<T>> createArrayList(int capacity)

equalsWith

public static <T> Predicate<T> equalsWith(T value)

createHashSet

public static <T> Supplier<Set<T>> createHashSet()

notificationOnNext

public static <T> Consumer<T> notificationOnNext(Consumer<? super Notification<T>> onNotification)

notificationOnError

public static <T> Consumer<Throwable> notificationOnError(Consumer<? super Notification<T>> onNotification)

notificationOnComplete

public static <T> Action notificationOnComplete(Consumer<? super Notification<T>> onNotification)

actionConsumer

public static <T> Consumer<T> actionConsumer(Action action)

isInstanceOf

public static <T,U> Predicate<T> isInstanceOf(Class<U> clazz)

predicateReverseFor

public static <T> Predicate<T> predicateReverseFor(BooleanSupplier supplier)

timestampWith

public static <T> Function<T,Timed<T>> timestampWith(TimeUnit unit,
 Scheduler scheduler)

toMapKeySelector

public static <T,K> BiConsumer<Map<K,T>,T> toMapKeySelector(Function<? super T, ? extends K> keySelector)

toMapKeyValueSelector

public static <T,K,V> BiConsumer<Map<K,V>,T> toMapKeyValueSelector(Function<? super T, ? extends K> keySelector,
 Function<? super T, ? extends V> valueSelector)

toMultimapKeyValueSelector

public static <T,K,V>
BiConsumer<Map<K, Collection<V>>, T> toMultimapKeyValueSelector(Function<? super T, ? extends K> keySelector,
 Function<? super T, ? extends V> valueSelector,
 Function<? super K, ? extends Collection<? super V>> collectionFactory)

naturalComparator

public static <T> Comparator<T> naturalComparator()

listSorter

public static <T> Function<List<T>,List<T>> listSorter(Comparator<? super T> comparator)

boundedConsumer

public static <T> Consumer<T> boundedConsumer(int bufferSize)