RxJava 3 3.1.8 · io.reactivex.rxjava3.internal.functions.Functions

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	Functions.ActionConsumer<T>
pack-priv static class	Functions.Array2Func<T1, T2, R>
pack-priv static class	Functions.Array3Func<T1, T2, T3, R>
pack-priv static class	Functions.Array4Func<T1, T2, T3, T4, R>
pack-priv static class	Functions.Array5Func<T1, T2, T3, T4, T5, R>
pack-priv static class	Functions.Array6Func<T1, T2, T3, T4, T5, T6, R>
pack-priv static class	Functions.Array7Func<T1, T2, T3, T4, T5, T6, T7, R>
pack-priv static class	Functions.Array8Func<T1, T2, T3, T4, T5, T6, T7, T8, R>
pack-priv static class	Functions.Array9Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, R>
pack-priv static class	Functions.ArrayListCapacityCallable<T>
pack-priv static class	Functions.BooleanSupplierPredicateReverse<T>
public static class	Functions.BoundedConsumer
pack-priv static class	Functions.CastToClass<T, U>
pack-priv static class	Functions.ClassFilter<T, U>
pack-priv static class	Functions.EmptyAction
pack-priv static class	Functions.EmptyConsumer
pack-priv static class	Functions.EmptyLongConsumer
pack-priv static class	Functions.EmptyRunnable
pack-priv static class	Functions.EqualsPredicate<T>
pack-priv static class	Functions.ErrorConsumer
pack-priv static class	Functions.FalsePredicate
pack-priv static class	Functions.FutureAction
pack-priv static enum	Functions.HashSetSupplier
pack-priv static class	Functions.Identity
pack-priv static class	Functions.JustValue<T, U>
pack-priv static class	Functions.ListSorter<T>
pack-priv static class	Functions.MaxRequestSubscription
pack-priv static enum	Functions.NaturalComparator
pack-priv static class	Functions.NotificationOnComplete<T>
pack-priv static class	Functions.NotificationOnError<T>
pack-priv static class	Functions.NotificationOnNext<T>
pack-priv static class	Functions.NullProvider
pack-priv static class	Functions.OnErrorMissingConsumer
pack-priv static class	Functions.TimestampFunction<T>
pack-priv static class	Functions.ToMapKeySelector<K, T>
pack-priv static class	Functions.ToMapKeyValueSelector<K, V, T>
pack-priv static class	Functions.ToMultimapKeyValueSelector<K, V, T>
pack-priv static class	Functions.TruePredicate

Field Summary

Modifier and Type	Field and Description
pack-priv static final Predicate<Object>	ALWAYS_FALSE
pack-priv static final Predicate<Object>	ALWAYS_TRUE
public static final Action	EMPTY_ACTION
pack-priv static final Consumer<Object>	EMPTY_CONSUMER
public static final LongConsumer	EMPTY_LONG_CONSUMER
public static final Runnable	EMPTY_RUNNABLE
public static final Consumer<Throwable>	ERROR_CONSUMER
pack-priv static final Function<Object, Object>	IDENTITY A singleton identity function.
pack-priv static final Supplier<Object>	NULL_SUPPLIER
public static final Consumer<Throwable>	ON_ERROR_MISSING Wraps the consumed Throwable into an OnErrorNotImplementedException and signals it to the plugin error handler.
public static final Consumer<Subscription>	REQUEST_MAX

Constructor Summary

Access	Constructor and Description
private	Functions() Utility class.

Method Summary

Modifier and Type	Method and Description
public static <T> Consumer<T>	actionConsumer(Action action)
public static <T> @NonNull Predicate<T>	alwaysFalse()
public static <T> @NonNull Predicate<T>	alwaysTrue()
public static <T> Consumer<T>	boundedConsumer(int bufferSize)
public static < the input value type T, the output and target type U> @NonNull Function<T, U>	Returns: the new Function instance castFunction(@NonNull Class<U> the target class target) Returns a function that cast the incoming values via a Class object.
public static <T> Supplier<List<T>>	createArrayList(int capacity)
public static <T> Supplier<Set<T>>	createHashSet()
public static < the consumed value type, the value is ignored T> Consumer<T>	Returns: an empty consumer that does nothing. emptyConsumer() Returns an empty consumer that does nothing.
public static <T> Predicate<T>	equalsWith(T value)
public static @NonNull Action	Returns: the new Action instance futureAction(@NonNull Future<?> the future to call get() on, not null future) Wraps the blocking get call of the Future into an Action.
public static < the input and output value type T> @NonNull Function<T, T>	Returns: the identity function identity() Returns an identity function that simply returns its argument.
public static <T, U> Predicate<T>	isInstanceOf(Class<U> clazz)
public static < the value type T> @NonNull Callable<T>	Returns: the new Callable instance justCallable(T the value to return value) Returns a Callable that returns the given value.
public static < the function's input type T, the value and return type of the function U> @NonNull Function<T, U>	Returns: the new Function instance justFunction(U the value to return value) Returns a Function that ignores its parameter and returns the given value.
public static < the value type T> @NonNull Supplier<T>	Returns: the new Callable instance justSupplier(T the value to return value) Returns a Supplier that returns the given value.
public static <T> Function<List<T>, List<T>>	listSorter(final Comparator<? super T> comparator)
public static <T> Comparator<T>	naturalComparator()
public static <T> Action	notificationOnComplete(Consumer<? super Notification<T>> onNotification)
public static <T> Consumer<Throwable>	notificationOnError(Consumer<? super Notification<T>> onNotification)
public static <T> Consumer<T>	notificationOnNext(Consumer<? super Notification<T>> onNotification)
public static <T> @NonNull Supplier<T>	nullSupplier()
public static <T> Predicate<T>	predicateReverseFor(BooleanSupplier supplier)
public static <T> Function<T, Timed<T>>	timestampWith(TimeUnit unit, Scheduler scheduler)
public static <T1, T2, R> @NonNull Function<Object[], R>	toFunction(@NonNull BiFunction<? super T1, ? super T2, ? extends R> f)
public static <T1, T2, T3, R> @NonNull Function<Object[], R>	toFunction(@NonNull Function3<T1, T2, T3, R> f)
public static <T1, T2, T3, T4, R> @NonNull Function<Object[], R>	toFunction(@NonNull Function4<T1, T2, T3, T4, R> f)
public static <T1, T2, T3, T4, T5, R> @NonNull Function<Object[], R>	toFunction(@NonNull Function5<T1, T2, T3, T4, T5, R> f)
public static <T1, T2, T3, T4, T5, T6, R> @NonNull Function<Object[], R>	toFunction(@NonNull Function6<T1, T2, T3, T4, T5, T6, R> f)
public 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)
public 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)
public 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)
public static <T, K> BiConsumer<Map<K, T>, T>	toMapKeySelector(final Function<? super T, ? extends K> keySelector)
public static <T, K, V> BiConsumer<Map<K, V>, T>	toMapKeyValueSelector(final Function<? super T, ? extends K> keySelector, final Function<? super T, ? extends V> valueSelector)
public static <T, K, V> BiConsumer<Map<K, Collection<V>>, T>	toMultimapKeyValueSelector(final Function<? super T, ? extends K> keySelector, final Function<? super T, ? extends V> valueSelector, final Function<? super K, ? extends Collection<? super V>> collectionFactory)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

public final Class Functions

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary