.class public final Lio/reactivex/internal/functions/Functions; .super Ljava/lang/Object; .source "Functions.java" # annotations .annotation system Ldalvik/annotation/MemberClasses; value = { Lio/reactivex/internal/functions/Functions$ListSorter;, Lio/reactivex/internal/functions/Functions$NaturalComparator;, Lio/reactivex/internal/functions/Functions$ToMultimapKeyValueSelector;, Lio/reactivex/internal/functions/Functions$ToMapKeyValueSelector;, Lio/reactivex/internal/functions/Functions$ToMapKeySelector;, Lio/reactivex/internal/functions/Functions$TimestampFunction;, Lio/reactivex/internal/functions/Functions$BooleanSupplierPredicateReverse;, Lio/reactivex/internal/functions/Functions$ClassFilter;, Lio/reactivex/internal/functions/Functions$ActionConsumer;, Lio/reactivex/internal/functions/Functions$NotificationOnComplete;, Lio/reactivex/internal/functions/Functions$NotificationOnError;, Lio/reactivex/internal/functions/Functions$NotificationOnNext;, Lio/reactivex/internal/functions/Functions$HashSetCallable;, Lio/reactivex/internal/functions/Functions$EqualsPredicate;, Lio/reactivex/internal/functions/Functions$ArrayListCapacityCallable;, Lio/reactivex/internal/functions/Functions$CastToClass;, Lio/reactivex/internal/functions/Functions$JustValue;, Lio/reactivex/internal/functions/Functions$FutureAction; } .end annotation # static fields .field static final ALWAYS_FALSE:Lio/reactivex/functions/Predicate; .annotation system Ldalvik/annotation/Signature; value = { "Lio/reactivex/functions/Predicate<", "Ljava/lang/Object;", ">;" } .end annotation .end field .field static final ALWAYS_TRUE:Lio/reactivex/functions/Predicate; .annotation system Ldalvik/annotation/Signature; value = { "Lio/reactivex/functions/Predicate<", "Ljava/lang/Object;", ">;" } .end annotation .end field .field public static final EMPTY_ACTION:Lio/reactivex/functions/Action; .field static final EMPTY_CONSUMER:Lio/reactivex/functions/Consumer; .annotation system Ldalvik/annotation/Signature; value = { "Lio/reactivex/functions/Consumer<", "Ljava/lang/Object;", ">;" } .end annotation .end field .field public static final EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer; .field public static final EMPTY_RUNNABLE:Ljava/lang/Runnable; .field public static final ERROR_CONSUMER:Lio/reactivex/functions/Consumer; .annotation system Ldalvik/annotation/Signature; value = { "Lio/reactivex/functions/Consumer<", "Ljava/lang/Throwable;", ">;" } .end annotation .end field .field static final IDENTITY:Lio/reactivex/functions/Function; .annotation system Ldalvik/annotation/Signature; value = { "Lio/reactivex/functions/Function<", "Ljava/lang/Object;", "Ljava/lang/Object;", ">;" } .end annotation .end field .field static final NATURAL_COMPARATOR:Ljava/util/Comparator; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/util/Comparator<", "Ljava/lang/Object;", ">;" } .end annotation .end field .field static final NULL_SUPPLIER:Ljava/util/concurrent/Callable; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/util/concurrent/Callable<", "Ljava/lang/Object;", ">;" } .end annotation .end field .field public static final REQUEST_MAX:Lio/reactivex/functions/Consumer; .annotation system Ldalvik/annotation/Signature; value = { "Lio/reactivex/functions/Consumer<", "Lorg/reactivestreams/Subscription;", ">;" } .end annotation .end field # direct methods .method static constructor ()V .locals 1 .line 152 new-instance v0, Lio/reactivex/internal/functions/Functions$9; invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$9;->()V sput-object v0, Lio/reactivex/internal/functions/Functions;->IDENTITY:Lio/reactivex/functions/Function; .line 174 new-instance v0, Lio/reactivex/internal/functions/Functions$10; invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$10;->()V sput-object v0, Lio/reactivex/internal/functions/Functions;->EMPTY_RUNNABLE:Ljava/lang/Runnable; .line 184 new-instance v0, Lio/reactivex/internal/functions/Functions$11; invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$11;->()V sput-object v0, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; .line 194 new-instance v0, Lio/reactivex/internal/functions/Functions$12; invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$12;->()V sput-object v0, Lio/reactivex/internal/functions/Functions;->EMPTY_CONSUMER:Lio/reactivex/functions/Consumer; .line 214 new-instance v0, Lio/reactivex/internal/functions/Functions$13; invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$13;->()V sput-object v0, Lio/reactivex/internal/functions/Functions;->ERROR_CONSUMER:Lio/reactivex/functions/Consumer; .line 221 new-instance v0, Lio/reactivex/internal/functions/Functions$14; invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$14;->()V sput-object v0, Lio/reactivex/internal/functions/Functions;->EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer; .line 226 new-instance v0, Lio/reactivex/internal/functions/Functions$15; invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$15;->()V sput-object v0, Lio/reactivex/internal/functions/Functions;->ALWAYS_TRUE:Lio/reactivex/functions/Predicate; .line 233 new-instance v0, Lio/reactivex/internal/functions/Functions$16; invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$16;->()V sput-object v0, Lio/reactivex/internal/functions/Functions;->ALWAYS_FALSE:Lio/reactivex/functions/Predicate; .line 240 new-instance v0, Lio/reactivex/internal/functions/Functions$17; invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$17;->()V sput-object v0, Lio/reactivex/internal/functions/Functions;->NULL_SUPPLIER:Ljava/util/concurrent/Callable; .line 247 new-instance v0, Lio/reactivex/internal/functions/Functions$18; invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$18;->()V sput-object v0, Lio/reactivex/internal/functions/Functions;->NATURAL_COMPARATOR:Ljava/util/Comparator; .line 642 new-instance v0, Lio/reactivex/internal/functions/Functions$19; invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$19;->()V sput-object v0, Lio/reactivex/internal/functions/Functions;->REQUEST_MAX:Lio/reactivex/functions/Consumer; return-void .end method .method private constructor ()V .locals 2 .line 31 invoke-direct {p0}, Ljava/lang/Object;->()V .line 32 new-instance v0, Ljava/lang/IllegalStateException; const-string v1, "No instances!" invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V throw v0 .end method .method public static actionConsumer(Lio/reactivex/functions/Action;)Lio/reactivex/functions/Consumer; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Action;", ")", "Lio/reactivex/functions/Consumer<", "TT;>;" } .end annotation .line 477 new-instance v0, Lio/reactivex/internal/functions/Functions$ActionConsumer; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$ActionConsumer;->(Lio/reactivex/functions/Action;)V return-object v0 .end method .method public static alwaysFalse()Lio/reactivex/functions/Predicate; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/functions/Predicate<", "TT;>;" } .end annotation .line 262 sget-object v0, Lio/reactivex/internal/functions/Functions;->ALWAYS_FALSE:Lio/reactivex/functions/Predicate; return-object v0 .end method .method public static alwaysTrue()Lio/reactivex/functions/Predicate; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/functions/Predicate<", "TT;>;" } .end annotation .line 257 sget-object v0, Lio/reactivex/internal/functions/Functions;->ALWAYS_TRUE:Lio/reactivex/functions/Predicate; return-object v0 .end method .method public static castFunction(Ljava/lang/Class;)Lio/reactivex/functions/Function; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Class<", "TU;>;)", "Lio/reactivex/functions/Function<", "TT;TU;>;" } .end annotation .line 362 new-instance v0, Lio/reactivex/internal/functions/Functions$CastToClass; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$CastToClass;->(Ljava/lang/Class;)V return-object v0 .end method .method public static createArrayList(I)Ljava/util/concurrent/Callable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(I)", "Ljava/util/concurrent/Callable<", "Ljava/util/List<", "TT;>;>;" } .end annotation .line 379 new-instance v0, Lio/reactivex/internal/functions/Functions$ArrayListCapacityCallable; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$ArrayListCapacityCallable;->(I)V return-object v0 .end method .method public static createHashSet()Ljava/util/concurrent/Callable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Ljava/util/concurrent/Callable<", "Ljava/util/Set<", "TT;>;>;" } .end annotation .line 409 sget-object v0, Lio/reactivex/internal/functions/Functions$HashSetCallable;->INSTANCE:Lio/reactivex/internal/functions/Functions$HashSetCallable; return-object v0 .end method .method public static emptyConsumer()Lio/reactivex/functions/Consumer; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/functions/Consumer<", "TT;>;" } .end annotation .line 211 sget-object v0, Lio/reactivex/internal/functions/Functions;->EMPTY_CONSUMER:Lio/reactivex/functions/Consumer; return-object v0 .end method .method public static equalsWith(Ljava/lang/Object;)Lio/reactivex/functions/Predicate; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(TT;)", "Lio/reactivex/functions/Predicate<", "TT;>;" } .end annotation .line 396 new-instance v0, Lio/reactivex/internal/functions/Functions$EqualsPredicate; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$EqualsPredicate;->(Ljava/lang/Object;)V return-object v0 .end method .method public static futureAction(Ljava/util/concurrent/Future;)Lio/reactivex/functions/Action; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "*>;)", "Lio/reactivex/functions/Action;" } .end annotation .line 299 new-instance v0, Lio/reactivex/internal/functions/Functions$FutureAction; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$FutureAction;->(Ljava/util/concurrent/Future;)V return-object v0 .end method .method public static identity()Lio/reactivex/functions/Function; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/functions/Function<", "TT;TT;>;" } .end annotation .line 171 sget-object v0, Lio/reactivex/internal/functions/Functions;->IDENTITY:Lio/reactivex/functions/Function; return-object v0 .end method .method public static isInstanceOf(Ljava/lang/Class;)Lio/reactivex/functions/Predicate; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Class<", "TU;>;)", "Lio/reactivex/functions/Predicate<", "TT;>;" } .end annotation .line 494 new-instance v0, Lio/reactivex/internal/functions/Functions$ClassFilter; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$ClassFilter;->(Ljava/lang/Class;)V return-object v0 .end method .method public static justCallable(Ljava/lang/Object;)Ljava/util/concurrent/Callable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(TT;)", "Ljava/util/concurrent/Callable<", "TT;>;" } .end annotation .line 327 new-instance v0, Lio/reactivex/internal/functions/Functions$JustValue; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$JustValue;->(Ljava/lang/Object;)V return-object v0 .end method .method public static justFunction(Ljava/lang/Object;)Lio/reactivex/functions/Function; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(TU;)", "Lio/reactivex/functions/Function<", "TT;TU;>;" } .end annotation .line 338 new-instance v0, Lio/reactivex/internal/functions/Functions$JustValue; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$JustValue;->(Ljava/lang/Object;)V return-object v0 .end method .method public static listSorter(Ljava/util/Comparator;)Lio/reactivex/functions/Function; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/Comparator<", "-TT;>;)", "Lio/reactivex/functions/Function<", "Ljava/util/List<", "TT;>;", "Ljava/util/List<", "TT;>;>;" } .end annotation .line 639 new-instance v0, Lio/reactivex/internal/functions/Functions$ListSorter; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$ListSorter;->(Ljava/util/Comparator;)V return-object v0 .end method .method public static naturalComparator()Ljava/util/Comparator; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Ljava/util/Comparator<", "TT;>;" } .end annotation .line 621 sget-object v0, Lio/reactivex/internal/functions/Functions$NaturalComparator;->INSTANCE:Lio/reactivex/internal/functions/Functions$NaturalComparator; return-object v0 .end method .method public static naturalOrder()Ljava/util/Comparator; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Ljava/util/Comparator<", "TT;>;" } .end annotation .line 277 sget-object v0, Lio/reactivex/internal/functions/Functions;->NATURAL_COMPARATOR:Ljava/util/Comparator; return-object v0 .end method .method public static notificationOnComplete(Lio/reactivex/functions/Consumer;)Lio/reactivex/functions/Action; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Consumer<", "-", "Lio/reactivex/Notification<", "TT;>;>;)", "Lio/reactivex/functions/Action;" } .end annotation .line 460 new-instance v0, Lio/reactivex/internal/functions/Functions$NotificationOnComplete; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$NotificationOnComplete;->(Lio/reactivex/functions/Consumer;)V return-object v0 .end method .method public static notificationOnError(Lio/reactivex/functions/Consumer;)Lio/reactivex/functions/Consumer; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Consumer<", "-", "Lio/reactivex/Notification<", "TT;>;>;)", "Lio/reactivex/functions/Consumer<", "Ljava/lang/Throwable;", ">;" } .end annotation .line 456 new-instance v0, Lio/reactivex/internal/functions/Functions$NotificationOnError; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$NotificationOnError;->(Lio/reactivex/functions/Consumer;)V return-object v0 .end method .method public static notificationOnNext(Lio/reactivex/functions/Consumer;)Lio/reactivex/functions/Consumer; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Consumer<", "-", "Lio/reactivex/Notification<", "TT;>;>;)", "Lio/reactivex/functions/Consumer<", "TT;>;" } .end annotation .line 452 new-instance v0, Lio/reactivex/internal/functions/Functions$NotificationOnNext; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$NotificationOnNext;->(Lio/reactivex/functions/Consumer;)V return-object v0 .end method .method public static nullSupplier()Ljava/util/concurrent/Callable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Ljava/util/concurrent/Callable<", "TT;>;" } .end annotation .line 267 sget-object v0, Lio/reactivex/internal/functions/Functions;->NULL_SUPPLIER:Ljava/util/concurrent/Callable; return-object v0 .end method .method public static predicateReverseFor(Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/functions/Predicate; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/BooleanSupplier;", ")", "Lio/reactivex/functions/Predicate<", "TT;>;" } .end annotation .line 511 new-instance v0, Lio/reactivex/internal/functions/Functions$BooleanSupplierPredicateReverse; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$BooleanSupplierPredicateReverse;->(Lio/reactivex/functions/BooleanSupplier;)V return-object v0 .end method .method public static timestampWith(Ljava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/functions/Function; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/functions/Function<", "TT;", "Lio/reactivex/schedulers/Timed<", "TT;>;>;" } .end annotation .line 531 new-instance v0, Lio/reactivex/internal/functions/Functions$TimestampFunction; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/functions/Functions$TimestampFunction;->(Ljava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)V return-object v0 .end method .method public static toFunction(Lio/reactivex/functions/BiFunction;)Lio/reactivex/functions/Function; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/BiFunction<", "-TT1;-TT2;+TR;>;)", "Lio/reactivex/functions/Function<", "[", "Ljava/lang/Object;", "TR;>;" } .end annotation const-string v0, "f is null" .line 37 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 38 new-instance v0, Lio/reactivex/internal/functions/Functions$1; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$1;->(Lio/reactivex/functions/BiFunction;)V return-object v0 .end method .method public static toFunction(Lio/reactivex/functions/Function3;)Lio/reactivex/functions/Function; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function3<", "TT1;TT2;TT3;TR;>;)", "Lio/reactivex/functions/Function<", "[", "Ljava/lang/Object;", "TR;>;" } .end annotation const-string v0, "f is null" .line 50 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 51 new-instance v0, Lio/reactivex/internal/functions/Functions$2; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$2;->(Lio/reactivex/functions/Function3;)V return-object v0 .end method .method public static toFunction(Lio/reactivex/functions/Function4;)Lio/reactivex/functions/Function; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function4<", "TT1;TT2;TT3;TT4;TR;>;)", "Lio/reactivex/functions/Function<", "[", "Ljava/lang/Object;", "TR;>;" } .end annotation const-string v0, "f is null" .line 64 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 65 new-instance v0, Lio/reactivex/internal/functions/Functions$3; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$3;->(Lio/reactivex/functions/Function4;)V return-object v0 .end method .method public static toFunction(Lio/reactivex/functions/Function5;)Lio/reactivex/functions/Function; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function5<", "TT1;TT2;TT3;TT4;TT5;TR;>;)", "Lio/reactivex/functions/Function<", "[", "Ljava/lang/Object;", "TR;>;" } .end annotation const-string v0, "f is null" .line 78 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 79 new-instance v0, Lio/reactivex/internal/functions/Functions$4; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$4;->(Lio/reactivex/functions/Function5;)V return-object v0 .end method .method public static toFunction(Lio/reactivex/functions/Function6;)Lio/reactivex/functions/Function; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function6<", "TT1;TT2;TT3;TT4;TT5;TT6;TR;>;)", "Lio/reactivex/functions/Function<", "[", "Ljava/lang/Object;", "TR;>;" } .end annotation const-string v0, "f is null" .line 93 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 94 new-instance v0, Lio/reactivex/internal/functions/Functions$5; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$5;->(Lio/reactivex/functions/Function6;)V return-object v0 .end method .method public static toFunction(Lio/reactivex/functions/Function7;)Lio/reactivex/functions/Function; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function7<", "TT1;TT2;TT3;TT4;TT5;TT6;TT7;TR;>;)", "Lio/reactivex/functions/Function<", "[", "Ljava/lang/Object;", "TR;>;" } .end annotation const-string v0, "f is null" .line 108 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 109 new-instance v0, Lio/reactivex/internal/functions/Functions$6; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$6;->(Lio/reactivex/functions/Function7;)V return-object v0 .end method .method public static toFunction(Lio/reactivex/functions/Function8;)Lio/reactivex/functions/Function; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function8<", "TT1;TT2;TT3;TT4;TT5;TT6;TT7;TT8;TR;>;)", "Lio/reactivex/functions/Function<", "[", "Ljava/lang/Object;", "TR;>;" } .end annotation const-string v0, "f is null" .line 123 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 124 new-instance v0, Lio/reactivex/internal/functions/Functions$7; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$7;->(Lio/reactivex/functions/Function8;)V return-object v0 .end method .method public static toFunction(Lio/reactivex/functions/Function9;)Lio/reactivex/functions/Function; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function9<", "TT1;TT2;TT3;TT4;TT5;TT6;TT7;TT8;TT9;TR;>;)", "Lio/reactivex/functions/Function<", "[", "Ljava/lang/Object;", "TR;>;" } .end annotation const-string v0, "f is null" .line 138 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 139 new-instance v0, Lio/reactivex/internal/functions/Functions$8; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$8;->(Lio/reactivex/functions/Function9;)V return-object v0 .end method .method public static toMapKeySelector(Lio/reactivex/functions/Function;)Lio/reactivex/functions/BiConsumer; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-TT;+TK;>;)", "Lio/reactivex/functions/BiConsumer<", "Ljava/util/Map<", "TK;TT;>;TT;>;" } .end annotation .line 549 new-instance v0, Lio/reactivex/internal/functions/Functions$ToMapKeySelector; invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$ToMapKeySelector;->(Lio/reactivex/functions/Function;)V return-object v0 .end method .method public static toMapKeyValueSelector(Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;)Lio/reactivex/functions/BiConsumer; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-TT;+TK;>;", "Lio/reactivex/functions/Function<", "-TT;+TV;>;)", "Lio/reactivex/functions/BiConsumer<", "Ljava/util/Map<", "TK;TV;>;TT;>;" } .end annotation .line 571 new-instance v0, Lio/reactivex/internal/functions/Functions$ToMapKeyValueSelector; invoke-direct {v0, p1, p0}, Lio/reactivex/internal/functions/Functions$ToMapKeyValueSelector;->(Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;)V return-object v0 .end method .method public static toMultimapKeyValueSelector(Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;)Lio/reactivex/functions/BiConsumer; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "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;>;" } .end annotation .line 606 new-instance v0, Lio/reactivex/internal/functions/Functions$ToMultimapKeyValueSelector; invoke-direct {v0, p2, p1, p0}, Lio/reactivex/internal/functions/Functions$ToMultimapKeyValueSelector;->(Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;)V return-object v0 .end method