public final class io.reactivex.internal.functions.Functions
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: io.reactivex.internal.functions.Functions
super_class: java.lang.Object
{
static final io.reactivex.functions.Function<java.lang.Object, java.lang.Object> IDENTITY;
descriptor: Lio/reactivex/functions/Function;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Lio/reactivex/functions/Function<Ljava/lang/Object;Ljava/lang/Object;>;
public static final java.lang.Runnable EMPTY_RUNNABLE;
descriptor: Ljava/lang/Runnable;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
public static final io.reactivex.functions.Action EMPTY_ACTION;
descriptor: Lio/reactivex/functions/Action;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
static final io.reactivex.functions.Consumer<java.lang.Object> EMPTY_CONSUMER;
descriptor: Lio/reactivex/functions/Consumer;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Lio/reactivex/functions/Consumer<Ljava/lang/Object;>;
public static final io.reactivex.functions.Consumer<java.lang.Throwable> ERROR_CONSUMER;
descriptor: Lio/reactivex/functions/Consumer;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/reactivex/functions/Consumer<Ljava/lang/Throwable;>;
public static final io.reactivex.functions.Consumer<java.lang.Throwable> ON_ERROR_MISSING;
descriptor: Lio/reactivex/functions/Consumer;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/reactivex/functions/Consumer<Ljava/lang/Throwable;>;
public static final io.reactivex.functions.LongConsumer EMPTY_LONG_CONSUMER;
descriptor: Lio/reactivex/functions/LongConsumer;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
static final io.reactivex.functions.Predicate<java.lang.Object> ALWAYS_TRUE;
descriptor: Lio/reactivex/functions/Predicate;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Lio/reactivex/functions/Predicate<Ljava/lang/Object;>;
static final io.reactivex.functions.Predicate<java.lang.Object> ALWAYS_FALSE;
descriptor: Lio/reactivex/functions/Predicate;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Lio/reactivex/functions/Predicate<Ljava/lang/Object;>;
static final java.util.concurrent.Callable<java.lang.Object> NULL_SUPPLIER;
descriptor: Ljava/util/concurrent/Callable;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/concurrent/Callable<Ljava/lang/Object;>;
static final java.util.Comparator<java.lang.Object> NATURAL_COMPARATOR;
descriptor: Ljava/util/Comparator;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/Comparator<Ljava/lang/Object;>;
public static final io.reactivex.functions.Consumer<org.reactivestreams.Subscription> REQUEST_MAX;
descriptor: Lio/reactivex/functions/Consumer;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/reactivex/functions/Consumer<Lorg/reactivestreams/Subscription;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new io.reactivex.internal.functions.Functions$Identity
dup
invokespecial io.reactivex.internal.functions.Functions$Identity.<init>:()V
putstatic io.reactivex.internal.functions.Functions.IDENTITY:Lio/reactivex/functions/Function;
1: new io.reactivex.internal.functions.Functions$EmptyRunnable
dup
invokespecial io.reactivex.internal.functions.Functions$EmptyRunnable.<init>:()V
putstatic io.reactivex.internal.functions.Functions.EMPTY_RUNNABLE:Ljava/lang/Runnable;
2: new io.reactivex.internal.functions.Functions$EmptyAction
dup
invokespecial io.reactivex.internal.functions.Functions$EmptyAction.<init>:()V
putstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
3: new io.reactivex.internal.functions.Functions$EmptyConsumer
dup
invokespecial io.reactivex.internal.functions.Functions$EmptyConsumer.<init>:()V
putstatic io.reactivex.internal.functions.Functions.EMPTY_CONSUMER:Lio/reactivex/functions/Consumer;
4: new io.reactivex.internal.functions.Functions$ErrorConsumer
dup
invokespecial io.reactivex.internal.functions.Functions$ErrorConsumer.<init>:()V
putstatic io.reactivex.internal.functions.Functions.ERROR_CONSUMER:Lio/reactivex/functions/Consumer;
5: new io.reactivex.internal.functions.Functions$OnErrorMissingConsumer
dup
invokespecial io.reactivex.internal.functions.Functions$OnErrorMissingConsumer.<init>:()V
putstatic io.reactivex.internal.functions.Functions.ON_ERROR_MISSING:Lio/reactivex/functions/Consumer;
6: new io.reactivex.internal.functions.Functions$EmptyLongConsumer
dup
invokespecial io.reactivex.internal.functions.Functions$EmptyLongConsumer.<init>:()V
putstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
7: new io.reactivex.internal.functions.Functions$TruePredicate
dup
invokespecial io.reactivex.internal.functions.Functions$TruePredicate.<init>:()V
putstatic io.reactivex.internal.functions.Functions.ALWAYS_TRUE:Lio/reactivex/functions/Predicate;
8: new io.reactivex.internal.functions.Functions$FalsePredicate
dup
invokespecial io.reactivex.internal.functions.Functions$FalsePredicate.<init>:()V
putstatic io.reactivex.internal.functions.Functions.ALWAYS_FALSE:Lio/reactivex/functions/Predicate;
9: new io.reactivex.internal.functions.Functions$NullCallable
dup
invokespecial io.reactivex.internal.functions.Functions$NullCallable.<init>:()V
putstatic io.reactivex.internal.functions.Functions.NULL_SUPPLIER:Ljava/util/concurrent/Callable;
10: new io.reactivex.internal.functions.Functions$NaturalObjectComparator
dup
invokespecial io.reactivex.internal.functions.Functions$NaturalObjectComparator.<init>:()V
putstatic io.reactivex.internal.functions.Functions.NATURAL_COMPARATOR:Ljava/util/Comparator;
11: new io.reactivex.internal.functions.Functions$MaxRequestSubscription
dup
invokespecial io.reactivex.internal.functions.Functions$MaxRequestSubscription.<init>:()V
putstatic io.reactivex.internal.functions.Functions.REQUEST_MAX:Lio/reactivex/functions/Consumer;
return
LocalVariableTable:
Start End Slot Name Signature
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: new java.lang.IllegalStateException
dup
ldc "No instances!"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/internal/functions/Functions;
public static <T1, T2, R> io.reactivex.functions.Function<java.lang.Object[], R> toFunction(io.reactivex.functions.BiFunction<? super T1, ? super T2, ? extends R>);
descriptor: (Lio/reactivex/functions/BiFunction;)Lio/reactivex/functions/Function;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "f is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.functions.Functions$Array2Func
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$Array2Func.<init>:(Lio/reactivex/functions/BiFunction;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 f Lio/reactivex/functions/BiFunction<-TT1;-TT2;+TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/functions/BiFunction<-TT1;-TT2;+TR;>;)Lio/reactivex/functions/Function<[Ljava/lang/Object;TR;>;
MethodParameters:
Name Flags
f final
public static <T1, T2, T3, R> io.reactivex.functions.Function<java.lang.Object[], R> toFunction(io.reactivex.functions.Function3<T1, T2, T3, R>);
descriptor: (Lio/reactivex/functions/Function3;)Lio/reactivex/functions/Function;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "f is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.functions.Functions$Array3Func
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$Array3Func.<init>:(Lio/reactivex/functions/Function3;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 f Lio/reactivex/functions/Function3<TT1;TT2;TT3;TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;T3:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/functions/Function3<TT1;TT2;TT3;TR;>;)Lio/reactivex/functions/Function<[Ljava/lang/Object;TR;>;
MethodParameters:
Name Flags
f final
public static <T1, T2, T3, T4, R> io.reactivex.functions.Function<java.lang.Object[], R> toFunction(io.reactivex.functions.Function4<T1, T2, T3, T4, R>);
descriptor: (Lio/reactivex/functions/Function4;)Lio/reactivex/functions/Function;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "f is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.functions.Functions$Array4Func
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$Array4Func.<init>:(Lio/reactivex/functions/Function4;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 f Lio/reactivex/functions/Function4<TT1;TT2;TT3;TT4;TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;T3:Ljava/lang/Object;T4:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/functions/Function4<TT1;TT2;TT3;TT4;TR;>;)Lio/reactivex/functions/Function<[Ljava/lang/Object;TR;>;
MethodParameters:
Name Flags
f final
public static <T1, T2, T3, T4, T5, R> io.reactivex.functions.Function<java.lang.Object[], R> toFunction(io.reactivex.functions.Function5<T1, T2, T3, T4, T5, R>);
descriptor: (Lio/reactivex/functions/Function5;)Lio/reactivex/functions/Function;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "f is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.functions.Functions$Array5Func
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$Array5Func.<init>:(Lio/reactivex/functions/Function5;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 f Lio/reactivex/functions/Function5<TT1;TT2;TT3;TT4;TT5;TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;T3:Ljava/lang/Object;T4:Ljava/lang/Object;T5:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/functions/Function5<TT1;TT2;TT3;TT4;TT5;TR;>;)Lio/reactivex/functions/Function<[Ljava/lang/Object;TR;>;
MethodParameters:
Name Flags
f final
public static <T1, T2, T3, T4, T5, T6, R> io.reactivex.functions.Function<java.lang.Object[], R> toFunction(io.reactivex.functions.Function6<T1, T2, T3, T4, T5, T6, R>);
descriptor: (Lio/reactivex/functions/Function6;)Lio/reactivex/functions/Function;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "f is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.functions.Functions$Array6Func
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$Array6Func.<init>:(Lio/reactivex/functions/Function6;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 f Lio/reactivex/functions/Function6<TT1;TT2;TT3;TT4;TT5;TT6;TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;T3:Ljava/lang/Object;T4:Ljava/lang/Object;T5:Ljava/lang/Object;T6:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/functions/Function6<TT1;TT2;TT3;TT4;TT5;TT6;TR;>;)Lio/reactivex/functions/Function<[Ljava/lang/Object;TR;>;
MethodParameters:
Name Flags
f final
public static <T1, T2, T3, T4, T5, T6, T7, R> io.reactivex.functions.Function<java.lang.Object[], R> toFunction(io.reactivex.functions.Function7<T1, T2, T3, T4, T5, T6, T7, R>);
descriptor: (Lio/reactivex/functions/Function7;)Lio/reactivex/functions/Function;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "f is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.functions.Functions$Array7Func
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$Array7Func.<init>:(Lio/reactivex/functions/Function7;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 f Lio/reactivex/functions/Function7<TT1;TT2;TT3;TT4;TT5;TT6;TT7;TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;T3:Ljava/lang/Object;T4:Ljava/lang/Object;T5:Ljava/lang/Object;T6:Ljava/lang/Object;T7:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/functions/Function7<TT1;TT2;TT3;TT4;TT5;TT6;TT7;TR;>;)Lio/reactivex/functions/Function<[Ljava/lang/Object;TR;>;
MethodParameters:
Name Flags
f final
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> io.reactivex.functions.Function<java.lang.Object[], R> toFunction(io.reactivex.functions.Function8<T1, T2, T3, T4, T5, T6, T7, T8, R>);
descriptor: (Lio/reactivex/functions/Function8;)Lio/reactivex/functions/Function;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "f is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.functions.Functions$Array8Func
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$Array8Func.<init>:(Lio/reactivex/functions/Function8;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 f Lio/reactivex/functions/Function8<TT1;TT2;TT3;TT4;TT5;TT6;TT7;TT8;TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;T3:Ljava/lang/Object;T4:Ljava/lang/Object;T5:Ljava/lang/Object;T6:Ljava/lang/Object;T7:Ljava/lang/Object;T8:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/functions/Function8<TT1;TT2;TT3;TT4;TT5;TT6;TT7;TT8;TR;>;)Lio/reactivex/functions/Function<[Ljava/lang/Object;TR;>;
MethodParameters:
Name Flags
f final
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> io.reactivex.functions.Function<java.lang.Object[], R> toFunction(io.reactivex.functions.Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R>);
descriptor: (Lio/reactivex/functions/Function9;)Lio/reactivex/functions/Function;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "f is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.functions.Functions$Array9Func
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$Array9Func.<init>:(Lio/reactivex/functions/Function9;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 f Lio/reactivex/functions/Function9<TT1;TT2;TT3;TT4;TT5;TT6;TT7;TT8;TT9;TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;T3:Ljava/lang/Object;T4:Ljava/lang/Object;T5:Ljava/lang/Object;T6:Ljava/lang/Object;T7:Ljava/lang/Object;T8:Ljava/lang/Object;T9:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/functions/Function9<TT1;TT2;TT3;TT4;TT5;TT6;TT7;TT8;TT9;TR;>;)Lio/reactivex/functions/Function<[Ljava/lang/Object;TR;>;
MethodParameters:
Name Flags
f final
public static <T> io.reactivex.functions.Function<T, T> identity();
descriptor: ()Lio/reactivex/functions/Function;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.internal.functions.Functions.IDENTITY:Lio/reactivex/functions/Function;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <T:Ljava/lang/Object;>()Lio/reactivex/functions/Function<TT;TT;>;
public static <T> io.reactivex.functions.Consumer<T> emptyConsumer();
descriptor: ()Lio/reactivex/functions/Consumer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.internal.functions.Functions.EMPTY_CONSUMER:Lio/reactivex/functions/Consumer;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <T:Ljava/lang/Object;>()Lio/reactivex/functions/Consumer<TT;>;
public static <T> io.reactivex.functions.Predicate<T> alwaysTrue();
descriptor: ()Lio/reactivex/functions/Predicate;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.internal.functions.Functions.ALWAYS_TRUE:Lio/reactivex/functions/Predicate;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <T:Ljava/lang/Object;>()Lio/reactivex/functions/Predicate<TT;>;
public static <T> io.reactivex.functions.Predicate<T> alwaysFalse();
descriptor: ()Lio/reactivex/functions/Predicate;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.internal.functions.Functions.ALWAYS_FALSE:Lio/reactivex/functions/Predicate;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <T:Ljava/lang/Object;>()Lio/reactivex/functions/Predicate<TT;>;
public static <T> java.util.concurrent.Callable<T> nullSupplier();
descriptor: ()Ljava/util/concurrent/Callable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.internal.functions.Functions.NULL_SUPPLIER:Ljava/util/concurrent/Callable;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <T:Ljava/lang/Object;>()Ljava/util/concurrent/Callable<TT;>;
public static <T> java.util.Comparator<T> naturalOrder();
descriptor: ()Ljava/util/Comparator;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.internal.functions.Functions.NATURAL_COMPARATOR:Ljava/util/Comparator;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <T:Ljava/lang/Object;>()Ljava/util/Comparator<TT;>;
public static io.reactivex.functions.Action futureAction(java.util.concurrent.Future<?>);
descriptor: (Ljava/util/concurrent/Future;)Lio/reactivex/functions/Action;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$FutureAction
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$FutureAction.<init>:(Ljava/util/concurrent/Future;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 future Ljava/util/concurrent/Future<*>;
Signature: (Ljava/util/concurrent/Future<*>;)Lio/reactivex/functions/Action;
MethodParameters:
Name Flags
future
public static <T> java.util.concurrent.Callable<T> justCallable(T);
descriptor: (Ljava/lang/Object;)Ljava/util/concurrent/Callable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$JustValue
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$JustValue.<init>:(Ljava/lang/Object;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 value TT;
Signature: <T:Ljava/lang/Object;>(TT;)Ljava/util/concurrent/Callable<TT;>;
MethodParameters:
Name Flags
value
public static <T, U> io.reactivex.functions.Function<T, U> justFunction(U);
descriptor: (Ljava/lang/Object;)Lio/reactivex/functions/Function;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$JustValue
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$JustValue.<init>:(Ljava/lang/Object;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 value TU;
Signature: <T:Ljava/lang/Object;U:Ljava/lang/Object;>(TU;)Lio/reactivex/functions/Function<TT;TU;>;
MethodParameters:
Name Flags
value
public static <T, U> io.reactivex.functions.Function<T, U> castFunction(java.lang.Class<U>);
descriptor: (Ljava/lang/Class;)Lio/reactivex/functions/Function;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$CastToClass
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$CastToClass.<init>:(Ljava/lang/Class;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 target Ljava/lang/Class<TU;>;
Signature: <T:Ljava/lang/Object;U:Ljava/lang/Object;>(Ljava/lang/Class<TU;>;)Lio/reactivex/functions/Function<TT;TU;>;
MethodParameters:
Name Flags
target
public static <T> java.util.concurrent.Callable<java.util.List<T>> createArrayList(int);
descriptor: (I)Ljava/util/concurrent/Callable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$ArrayListCapacityCallable
dup
iload 0
invokespecial io.reactivex.internal.functions.Functions$ArrayListCapacityCallable.<init>:(I)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 capacity I
Signature: <T:Ljava/lang/Object;>(I)Ljava/util/concurrent/Callable<Ljava/util/List<TT;>;>;
MethodParameters:
Name Flags
capacity
public static <T> io.reactivex.functions.Predicate<T> equalsWith(T);
descriptor: (Ljava/lang/Object;)Lio/reactivex/functions/Predicate;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$EqualsPredicate
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$EqualsPredicate.<init>:(Ljava/lang/Object;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 value TT;
Signature: <T:Ljava/lang/Object;>(TT;)Lio/reactivex/functions/Predicate<TT;>;
MethodParameters:
Name Flags
value
public static <T> java.util.concurrent.Callable<java.util.Set<T>> createHashSet();
descriptor: ()Ljava/util/concurrent/Callable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.internal.functions.Functions$HashSetCallable.INSTANCE:Lio/reactivex/internal/functions/Functions$HashSetCallable;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <T:Ljava/lang/Object;>()Ljava/util/concurrent/Callable<Ljava/util/Set<TT;>;>;
public static <T> io.reactivex.functions.Consumer<T> notificationOnNext(io.reactivex.functions.Consumer<? super io.reactivex.Notification<T>>);
descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/functions/Consumer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$NotificationOnNext
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$NotificationOnNext.<init>:(Lio/reactivex/functions/Consumer;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 onNotification Lio/reactivex/functions/Consumer<-Lio/reactivex/Notification<TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/functions/Consumer<-Lio/reactivex/Notification<TT;>;>;)Lio/reactivex/functions/Consumer<TT;>;
MethodParameters:
Name Flags
onNotification
public static <T> io.reactivex.functions.Consumer<java.lang.Throwable> notificationOnError(io.reactivex.functions.Consumer<? super io.reactivex.Notification<T>>);
descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/functions/Consumer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$NotificationOnError
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$NotificationOnError.<init>:(Lio/reactivex/functions/Consumer;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 onNotification Lio/reactivex/functions/Consumer<-Lio/reactivex/Notification<TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/functions/Consumer<-Lio/reactivex/Notification<TT;>;>;)Lio/reactivex/functions/Consumer<Ljava/lang/Throwable;>;
MethodParameters:
Name Flags
onNotification
public static <T> io.reactivex.functions.Action notificationOnComplete(io.reactivex.functions.Consumer<? super io.reactivex.Notification<T>>);
descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/functions/Action;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$NotificationOnComplete
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$NotificationOnComplete.<init>:(Lio/reactivex/functions/Consumer;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 onNotification Lio/reactivex/functions/Consumer<-Lio/reactivex/Notification<TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/functions/Consumer<-Lio/reactivex/Notification<TT;>;>;)Lio/reactivex/functions/Action;
MethodParameters:
Name Flags
onNotification
public static <T> io.reactivex.functions.Consumer<T> actionConsumer(io.reactivex.functions.Action);
descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/functions/Consumer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$ActionConsumer
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$ActionConsumer.<init>:(Lio/reactivex/functions/Action;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 action Lio/reactivex/functions/Action;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/functions/Action;)Lio/reactivex/functions/Consumer<TT;>;
MethodParameters:
Name Flags
action
public static <T, U> io.reactivex.functions.Predicate<T> isInstanceOf(java.lang.Class<U>);
descriptor: (Ljava/lang/Class;)Lio/reactivex/functions/Predicate;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$ClassFilter
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$ClassFilter.<init>:(Ljava/lang/Class;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 clazz Ljava/lang/Class<TU;>;
Signature: <T:Ljava/lang/Object;U:Ljava/lang/Object;>(Ljava/lang/Class<TU;>;)Lio/reactivex/functions/Predicate<TT;>;
MethodParameters:
Name Flags
clazz
public static <T> io.reactivex.functions.Predicate<T> predicateReverseFor(io.reactivex.functions.BooleanSupplier);
descriptor: (Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/functions/Predicate;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$BooleanSupplierPredicateReverse
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$BooleanSupplierPredicateReverse.<init>:(Lio/reactivex/functions/BooleanSupplier;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 supplier Lio/reactivex/functions/BooleanSupplier;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/functions/Predicate<TT;>;
MethodParameters:
Name Flags
supplier
public static <T> io.reactivex.functions.Function<T, io.reactivex.schedulers.Timed<T>> timestampWith(java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
descriptor: (Ljava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/functions/Function;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new io.reactivex.internal.functions.Functions$TimestampFunction
dup
aload 0
aload 1
invokespecial io.reactivex.internal.functions.Functions$TimestampFunction.<init>:(Ljava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 unit Ljava/util/concurrent/TimeUnit;
0 1 1 scheduler Lio/reactivex/Scheduler;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/functions/Function<TT;Lio/reactivex/schedulers/Timed<TT;>;>;
MethodParameters:
Name Flags
unit
scheduler
public static <T, K> io.reactivex.functions.BiConsumer<java.util.Map<K, T>, T> toMapKeySelector(io.reactivex.functions.Function<? super T, ? extends K>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/functions/BiConsumer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$ToMapKeySelector
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$ToMapKeySelector.<init>:(Lio/reactivex/functions/Function;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 keySelector Lio/reactivex/functions/Function<-TT;+TK;>;
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+TK;>;)Lio/reactivex/functions/BiConsumer<Ljava/util/Map<TK;TT;>;TT;>;
MethodParameters:
Name Flags
keySelector final
public static <T, K, V> io.reactivex.functions.BiConsumer<java.util.Map<K, V>, T> toMapKeyValueSelector(io.reactivex.functions.Function<? super T, ? extends K>, io.reactivex.functions.Function<? super T, ? extends V>);
descriptor: (Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;)Lio/reactivex/functions/BiConsumer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new io.reactivex.internal.functions.Functions$ToMapKeyValueSelector
dup
aload 1
aload 0
invokespecial io.reactivex.internal.functions.Functions$ToMapKeyValueSelector.<init>:(Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 keySelector Lio/reactivex/functions/Function<-TT;+TK;>;
0 1 1 valueSelector Lio/reactivex/functions/Function<-TT;+TV;>;
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+TK;>;Lio/reactivex/functions/Function<-TT;+TV;>;)Lio/reactivex/functions/BiConsumer<Ljava/util/Map<TK;TV;>;TT;>;
MethodParameters:
Name Flags
keySelector final
valueSelector final
public static <T, K, V> io.reactivex.functions.BiConsumer<java.util.Map<K, java.util.Collection<V>>, T> toMultimapKeyValueSelector(io.reactivex.functions.Function<? super T, ? extends K>, io.reactivex.functions.Function<? super T, ? extends V>, io.reactivex.functions.Function<? super K, ? extends java.util.Collection<? super V>>);
descriptor: (Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;)Lio/reactivex/functions/BiConsumer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new io.reactivex.internal.functions.Functions$ToMultimapKeyValueSelector
dup
aload 2
aload 1
aload 0
invokespecial io.reactivex.internal.functions.Functions$ToMultimapKeyValueSelector.<init>:(Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 keySelector Lio/reactivex/functions/Function<-TT;+TK;>;
0 1 1 valueSelector Lio/reactivex/functions/Function<-TT;+TV;>;
0 1 2 collectionFactory Lio/reactivex/functions/Function<-TK;+Ljava/util/Collection<-TV;>;>;
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+TK;>;Lio/reactivex/functions/Function<-TT;+TV;>;Lio/reactivex/functions/Function<-TK;+Ljava/util/Collection<-TV;>;>;)Lio/reactivex/functions/BiConsumer<Ljava/util/Map<TK;Ljava/util/Collection<TV;>;>;TT;>;
MethodParameters:
Name Flags
keySelector final
valueSelector final
collectionFactory final
public static <T> java.util.Comparator<T> naturalComparator();
descriptor: ()Ljava/util/Comparator;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.internal.functions.Functions$NaturalComparator.INSTANCE:Lio/reactivex/internal/functions/Functions$NaturalComparator;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <T:Ljava/lang/Object;>()Ljava/util/Comparator<TT;>;
public static <T> io.reactivex.functions.Function<java.util.List<T>, java.util.List<T>> listSorter(java.util.Comparator<? super T>);
descriptor: (Ljava/util/Comparator;)Lio/reactivex/functions/Function;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$ListSorter
dup
aload 0
invokespecial io.reactivex.internal.functions.Functions$ListSorter.<init>:(Ljava/util/Comparator;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 comparator Ljava/util/Comparator<-TT;>;
Signature: <T:Ljava/lang/Object;>(Ljava/util/Comparator<-TT;>;)Lio/reactivex/functions/Function<Ljava/util/List<TT;>;Ljava/util/List<TT;>;>;
MethodParameters:
Name Flags
comparator final
public static <T> io.reactivex.functions.Consumer<T> boundedConsumer(int);
descriptor: (I)Lio/reactivex/functions/Consumer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.functions.Functions$BoundedConsumer
dup
iload 0
invokespecial io.reactivex.internal.functions.Functions$BoundedConsumer.<init>:(I)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 bufferSize I
Signature: <T:Ljava/lang/Object;>(I)Lio/reactivex/functions/Consumer<TT;>;
MethodParameters:
Name Flags
bufferSize
}
SourceFile: "Functions.java"
NestMembers:
io.reactivex.internal.functions.Functions$ActionConsumer io.reactivex.internal.functions.Functions$Array2Func io.reactivex.internal.functions.Functions$Array3Func io.reactivex.internal.functions.Functions$Array4Func io.reactivex.internal.functions.Functions$Array5Func io.reactivex.internal.functions.Functions$Array6Func io.reactivex.internal.functions.Functions$Array7Func io.reactivex.internal.functions.Functions$Array8Func io.reactivex.internal.functions.Functions$Array9Func io.reactivex.internal.functions.Functions$ArrayListCapacityCallable io.reactivex.internal.functions.Functions$BooleanSupplierPredicateReverse io.reactivex.internal.functions.Functions$BoundedConsumer io.reactivex.internal.functions.Functions$CastToClass io.reactivex.internal.functions.Functions$ClassFilter io.reactivex.internal.functions.Functions$EmptyAction io.reactivex.internal.functions.Functions$EmptyConsumer io.reactivex.internal.functions.Functions$EmptyLongConsumer io.reactivex.internal.functions.Functions$EmptyRunnable io.reactivex.internal.functions.Functions$EqualsPredicate io.reactivex.internal.functions.Functions$ErrorConsumer io.reactivex.internal.functions.Functions$FalsePredicate io.reactivex.internal.functions.Functions$FutureAction io.reactivex.internal.functions.Functions$HashSetCallable io.reactivex.internal.functions.Functions$Identity io.reactivex.internal.functions.Functions$JustValue io.reactivex.internal.functions.Functions$ListSorter io.reactivex.internal.functions.Functions$MaxRequestSubscription io.reactivex.internal.functions.Functions$NaturalComparator io.reactivex.internal.functions.Functions$NaturalObjectComparator io.reactivex.internal.functions.Functions$NotificationOnComplete io.reactivex.internal.functions.Functions$NotificationOnError io.reactivex.internal.functions.Functions$NotificationOnNext io.reactivex.internal.functions.Functions$NullCallable io.reactivex.internal.functions.Functions$OnErrorMissingConsumer io.reactivex.internal.functions.Functions$TimestampFunction io.reactivex.internal.functions.Functions$ToMapKeySelector io.reactivex.internal.functions.Functions$ToMapKeyValueSelector io.reactivex.internal.functions.Functions$ToMultimapKeyValueSelector io.reactivex.internal.functions.Functions$TruePredicate
InnerClasses:
final ActionConsumer = io.reactivex.internal.functions.Functions$ActionConsumer of io.reactivex.internal.functions.Functions
final Array2Func = io.reactivex.internal.functions.Functions$Array2Func of io.reactivex.internal.functions.Functions
final Array3Func = io.reactivex.internal.functions.Functions$Array3Func of io.reactivex.internal.functions.Functions
final Array4Func = io.reactivex.internal.functions.Functions$Array4Func of io.reactivex.internal.functions.Functions
final Array5Func = io.reactivex.internal.functions.Functions$Array5Func of io.reactivex.internal.functions.Functions
final Array6Func = io.reactivex.internal.functions.Functions$Array6Func of io.reactivex.internal.functions.Functions
final Array7Func = io.reactivex.internal.functions.Functions$Array7Func of io.reactivex.internal.functions.Functions
final Array8Func = io.reactivex.internal.functions.Functions$Array8Func of io.reactivex.internal.functions.Functions
final Array9Func = io.reactivex.internal.functions.Functions$Array9Func of io.reactivex.internal.functions.Functions
final ArrayListCapacityCallable = io.reactivex.internal.functions.Functions$ArrayListCapacityCallable of io.reactivex.internal.functions.Functions
final BooleanSupplierPredicateReverse = io.reactivex.internal.functions.Functions$BooleanSupplierPredicateReverse of io.reactivex.internal.functions.Functions
public BoundedConsumer = io.reactivex.internal.functions.Functions$BoundedConsumer of io.reactivex.internal.functions.Functions
final CastToClass = io.reactivex.internal.functions.Functions$CastToClass of io.reactivex.internal.functions.Functions
final ClassFilter = io.reactivex.internal.functions.Functions$ClassFilter of io.reactivex.internal.functions.Functions
final EmptyAction = io.reactivex.internal.functions.Functions$EmptyAction of io.reactivex.internal.functions.Functions
final EmptyConsumer = io.reactivex.internal.functions.Functions$EmptyConsumer of io.reactivex.internal.functions.Functions
final EmptyLongConsumer = io.reactivex.internal.functions.Functions$EmptyLongConsumer of io.reactivex.internal.functions.Functions
final EmptyRunnable = io.reactivex.internal.functions.Functions$EmptyRunnable of io.reactivex.internal.functions.Functions
final EqualsPredicate = io.reactivex.internal.functions.Functions$EqualsPredicate of io.reactivex.internal.functions.Functions
final ErrorConsumer = io.reactivex.internal.functions.Functions$ErrorConsumer of io.reactivex.internal.functions.Functions
final FalsePredicate = io.reactivex.internal.functions.Functions$FalsePredicate of io.reactivex.internal.functions.Functions
final FutureAction = io.reactivex.internal.functions.Functions$FutureAction of io.reactivex.internal.functions.Functions
final HashSetCallable = io.reactivex.internal.functions.Functions$HashSetCallable of io.reactivex.internal.functions.Functions
final Identity = io.reactivex.internal.functions.Functions$Identity of io.reactivex.internal.functions.Functions
final JustValue = io.reactivex.internal.functions.Functions$JustValue of io.reactivex.internal.functions.Functions
final ListSorter = io.reactivex.internal.functions.Functions$ListSorter of io.reactivex.internal.functions.Functions
final MaxRequestSubscription = io.reactivex.internal.functions.Functions$MaxRequestSubscription of io.reactivex.internal.functions.Functions
final NaturalComparator = io.reactivex.internal.functions.Functions$NaturalComparator of io.reactivex.internal.functions.Functions
final NaturalObjectComparator = io.reactivex.internal.functions.Functions$NaturalObjectComparator of io.reactivex.internal.functions.Functions
final NotificationOnComplete = io.reactivex.internal.functions.Functions$NotificationOnComplete of io.reactivex.internal.functions.Functions
final NotificationOnError = io.reactivex.internal.functions.Functions$NotificationOnError of io.reactivex.internal.functions.Functions
final NotificationOnNext = io.reactivex.internal.functions.Functions$NotificationOnNext of io.reactivex.internal.functions.Functions
final NullCallable = io.reactivex.internal.functions.Functions$NullCallable of io.reactivex.internal.functions.Functions
final OnErrorMissingConsumer = io.reactivex.internal.functions.Functions$OnErrorMissingConsumer of io.reactivex.internal.functions.Functions
final TimestampFunction = io.reactivex.internal.functions.Functions$TimestampFunction of io.reactivex.internal.functions.Functions
final ToMapKeySelector = io.reactivex.internal.functions.Functions$ToMapKeySelector of io.reactivex.internal.functions.Functions
final ToMapKeyValueSelector = io.reactivex.internal.functions.Functions$ToMapKeyValueSelector of io.reactivex.internal.functions.Functions
final ToMultimapKeyValueSelector = io.reactivex.internal.functions.Functions$ToMultimapKeyValueSelector of io.reactivex.internal.functions.Functions
final TruePredicate = io.reactivex.internal.functions.Functions$TruePredicate of io.reactivex.internal.functions.Functions