.class public abstract Lio/reactivex/Single; .super Ljava/lang/Object; .source "Single.java" # interfaces .implements Lio/reactivex/SingleSource; # annotations .annotation system Ldalvik/annotation/Signature; value = { "", "Ljava/lang/Object;", "Lio/reactivex/SingleSource<", "TT;>;" } .end annotation # direct methods .method public constructor ()V .locals 0 .line 59 invoke-direct {p0}, Ljava/lang/Object;->()V return-void .end method .method public static amb(Ljava/lang/Iterable;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lio/reactivex/SingleSource<", "+TT;>;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 76 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 77 new-instance v0, Lio/reactivex/internal/operators/single/SingleAmb; const/4 v1, 0x0 invoke-direct {v0, v1, p0}, Lio/reactivex/internal/operators/single/SingleAmb;->([Lio/reactivex/SingleSource;Ljava/lang/Iterable;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static varargs ambArray([Lio/reactivex/SingleSource;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 96 array-length v0, p0 if-nez v0, :cond_0 .line 97 invoke-static {}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->emptyThrower()Ljava/util/concurrent/Callable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->error(Ljava/util/concurrent/Callable;)Lio/reactivex/Single; move-result-object p0 return-object p0 .line 99 :cond_0 array-length v0, p0 const/4 v1, 0x1 if-ne v0, v1, :cond_1 const/4 v0, 0x0 .line 100 aget-object p0, p0, v0 invoke-static {p0}, Lio/reactivex/Single;->wrap(Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p0 return-object p0 .line 102 :cond_1 new-instance v0, Lio/reactivex/internal/operators/single/SingleAmb; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/internal/operators/single/SingleAmb;->([Lio/reactivex/SingleSource;Ljava/lang/Iterable;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static concat(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT;>;", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 218 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 219 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 .line 220 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 invoke-static {v0}, Lio/reactivex/Flowable;->fromArray([Ljava/lang/Object;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->concat(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static concat(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT;>;", "Lio/reactivex/SingleSource<", "+TT;>;", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 252 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 253 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 254 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x3 .line 255 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 invoke-static {v0}, Lio/reactivex/Flowable;->fromArray([Ljava/lang/Object;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->concat(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static concat(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT;>;", "Lio/reactivex/SingleSource<", "+TT;>;", "Lio/reactivex/SingleSource<", "+TT;>;", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 289 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 290 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 291 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 292 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x4 .line 293 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 invoke-static {v0}, Lio/reactivex/Flowable;->fromArray([Ljava/lang/Object;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->concat(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static concat(Ljava/lang/Iterable;)Lio/reactivex/Flowable; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lio/reactivex/SingleSource<", "+TT;>;>;)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 123 invoke-static {p0}, Lio/reactivex/Flowable;->fromIterable(Ljava/lang/Iterable;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->concat(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static concat(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "+", "Lio/reactivex/SingleSource<", "+TT;>;>;)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x2 .line 164 invoke-static {p0, v0}, Lio/reactivex/Single;->concat(Lorg/reactivestreams/Publisher;I)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static concat(Lorg/reactivestreams/Publisher;I)Lio/reactivex/Flowable; .locals 3 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "+", "Lio/reactivex/SingleSource<", "+TT;>;>;I)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "prefetch" .line 188 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->verifyPositive(ILjava/lang/String;)I .line 189 new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableConcatMap; invoke-static {}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->toFlowable()Lio/reactivex/functions/Function; move-result-object v1 sget-object v2, Lio/reactivex/internal/util/ErrorMode;->IMMEDIATE:Lio/reactivex/internal/util/ErrorMode; invoke-direct {v0, p0, v1, p1, v2}, Lio/reactivex/internal/operators/flowable/FlowableConcatMap;->(Lorg/reactivestreams/Publisher;Lio/reactivex/functions/Function;ILio/reactivex/internal/util/ErrorMode;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Flowable;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static concat(Lio/reactivex/ObservableSource;)Lio/reactivex/Observable; .locals 4 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/ObservableSource<", "+", "Lio/reactivex/SingleSource<", "+TT;>;>;)", "Lio/reactivex/Observable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 142 new-instance v0, Lio/reactivex/internal/operators/observable/ObservableConcatMap; invoke-static {}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->toObservable()Lio/reactivex/functions/Function; move-result-object v1 sget-object v2, Lio/reactivex/internal/util/ErrorMode;->IMMEDIATE:Lio/reactivex/internal/util/ErrorMode; const/4 v3, 0x2 invoke-direct {v0, p0, v1, v3, v2}, Lio/reactivex/internal/operators/observable/ObservableConcatMap;->(Lio/reactivex/ObservableSource;Lio/reactivex/functions/Function;ILio/reactivex/internal/util/ErrorMode;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Observable;)Lio/reactivex/Observable; move-result-object p0 return-object p0 .end method .method public static varargs concatArray([Lio/reactivex/SingleSource;)Lio/reactivex/Flowable; .locals 4 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 315 new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableConcatMap; invoke-static {p0}, Lio/reactivex/Flowable;->fromArray([Ljava/lang/Object;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->toFlowable()Lio/reactivex/functions/Function; move-result-object v1 sget-object v2, Lio/reactivex/internal/util/ErrorMode;->BOUNDARY:Lio/reactivex/internal/util/ErrorMode; const/4 v3, 0x2 invoke-direct {v0, p0, v1, v3, v2}, Lio/reactivex/internal/operators/flowable/FlowableConcatMap;->(Lorg/reactivestreams/Publisher;Lio/reactivex/functions/Function;ILio/reactivex/internal/util/ErrorMode;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Flowable;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static create(Lio/reactivex/SingleOnSubscribe;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleOnSubscribe<", "TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source is null" .line 356 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 357 new-instance v0, Lio/reactivex/internal/operators/single/SingleCreate; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleCreate;->(Lio/reactivex/SingleOnSubscribe;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static defer(Ljava/util/concurrent/Callable;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+", "Lio/reactivex/SingleSource<", "+TT;>;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "singleSupplier is null" .line 375 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 376 new-instance v0, Lio/reactivex/internal/operators/single/SingleDefer; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleDefer;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static equals(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT;>;", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Single<", "Ljava/lang/Boolean;", ">;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "first is null" .line 895 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "second is null" .line 896 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 897 new-instance v0, Lio/reactivex/internal/operators/single/SingleEquals; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleEquals;->(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static error(Ljava/lang/Throwable;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Throwable;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "error is null" .line 418 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 419 invoke-static {p0}, Lio/reactivex/internal/functions/Functions;->justCallable(Ljava/lang/Object;)Ljava/util/concurrent/Callable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->error(Ljava/util/concurrent/Callable;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static error(Ljava/util/concurrent/Callable;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+", "Ljava/lang/Throwable;", ">;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "errorSupplier is null" .line 393 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 394 new-instance v0, Lio/reactivex/internal/operators/single/SingleError; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleError;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static fromCallable(Ljava/util/concurrent/Callable;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "callable is null" .line 442 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 443 new-instance v0, Lio/reactivex/internal/operators/single/SingleFromCallable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleFromCallable;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static fromFuture(Ljava/util/concurrent/Future;)Lio/reactivex/Single; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "+TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 472 invoke-static {p0}, Lio/reactivex/Flowable;->fromFuture(Ljava/util/concurrent/Future;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->toSingle(Lio/reactivex/Flowable;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static fromFuture(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "+TT;>;J", "Ljava/util/concurrent/TimeUnit;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 505 invoke-static {p0, p1, p2, p3}, Lio/reactivex/Flowable;->fromFuture(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->toSingle(Lio/reactivex/Flowable;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static fromFuture(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "+TT;>;J", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation .line 540 invoke-static {p0, p1, p2, p3, p4}, Lio/reactivex/Flowable;->fromFuture(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->toSingle(Lio/reactivex/Flowable;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static fromFuture(Ljava/util/concurrent/Future;Lio/reactivex/Scheduler;)Lio/reactivex/Single; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "+TT;>;", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation .line 570 invoke-static {p0, p1}, Lio/reactivex/Flowable;->fromFuture(Ljava/util/concurrent/Future;Lio/reactivex/Scheduler;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->toSingle(Lio/reactivex/Flowable;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static fromObservable(Lio/reactivex/ObservableSource;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/ObservableSource<", "+TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "observableSource is null" .line 614 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 615 new-instance v0, Lio/reactivex/internal/operators/observable/ObservableSingleSingle; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/internal/operators/observable/ObservableSingleSingle;->(Lio/reactivex/ObservableSource;Ljava/lang/Object;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static fromPublisher(Lorg/reactivestreams/Publisher;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "+TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "publisher is null" .line 592 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 593 new-instance v0, Lio/reactivex/internal/operators/single/SingleFromPublisher; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleFromPublisher;->(Lorg/reactivestreams/Publisher;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static just(Ljava/lang/Object;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(TT;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "value is null" .line 640 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 641 new-instance v0, Lio/reactivex/internal/operators/single/SingleJust; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleJust;->(Ljava/lang/Object;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static merge(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT;>;", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 742 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 743 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 .line 744 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 invoke-static {v0}, Lio/reactivex/Flowable;->fromArray([Ljava/lang/Object;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->merge(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static merge(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT;>;", "Lio/reactivex/SingleSource<", "+TT;>;", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 779 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 780 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 781 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x3 .line 782 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 invoke-static {v0}, Lio/reactivex/Flowable;->fromArray([Ljava/lang/Object;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->merge(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static merge(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT;>;", "Lio/reactivex/SingleSource<", "+TT;>;", "Lio/reactivex/SingleSource<", "+TT;>;", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 819 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 820 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 821 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 822 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x4 .line 823 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 invoke-static {v0}, Lio/reactivex/Flowable;->fromArray([Ljava/lang/Object;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->merge(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static merge(Ljava/lang/Iterable;)Lio/reactivex/Flowable; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lio/reactivex/SingleSource<", "+TT;>;>;)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 662 invoke-static {p0}, Lio/reactivex/Flowable;->fromIterable(Ljava/lang/Iterable;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->merge(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static merge(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "+", "Lio/reactivex/SingleSource<", "+TT;>;>;)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 684 new-instance v6, Lio/reactivex/internal/operators/flowable/FlowableFlatMap; invoke-static {}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->toFlowable()Lio/reactivex/functions/Function; move-result-object v2 invoke-static {}, Lio/reactivex/Flowable;->bufferSize()I move-result v5 const/4 v3, 0x0 const v4, 0x7fffffff move-object v0, v6 move-object v1, p0 invoke-direct/range {v0 .. v5}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap;->(Lorg/reactivestreams/Publisher;Lio/reactivex/functions/Function;ZII)V invoke-static {v6}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Flowable;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static merge(Lio/reactivex/SingleSource;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+", "Lio/reactivex/SingleSource<", "+TT;>;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source is null" .line 709 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 710 new-instance v0, Lio/reactivex/internal/operators/single/SingleFlatMap; invoke-static {}, Lio/reactivex/internal/functions/Functions;->identity()Lio/reactivex/functions/Function; move-result-object v1 invoke-direct {v0, p0, v1}, Lio/reactivex/internal/operators/single/SingleFlatMap;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static never()Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 840 sget-object v0, Lio/reactivex/internal/operators/single/SingleNever;->INSTANCE:Lio/reactivex/Single; invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object v0 return-object v0 .end method .method private timeout0(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource;)Lio/reactivex/Single; .locals 8 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/Scheduler;", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation const-string v0, "unit is null" .line 2886 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "scheduler is null" .line 2887 invoke-static {p4, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2888 new-instance v0, Lio/reactivex/internal/operators/single/SingleTimeout; move-object v1, v0 move-object v2, p0 move-wide v3, p1 move-object v5, p3 move-object v6, p4 move-object v7, p5 invoke-direct/range {v1 .. v7}, Lio/reactivex/internal/operators/single/SingleTimeout;->(Lio/reactivex/SingleSource;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public static timer(JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lio/reactivex/Single<", "Ljava/lang/Long;", ">;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 857 invoke-static {}, Lio/reactivex/schedulers/Schedulers;->computation()Lio/reactivex/Scheduler; move-result-object v0 invoke-static {p0, p1, p2, v0}, Lio/reactivex/Single;->timer(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static timer(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Single<", "Ljava/lang/Long;", ">;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "unit is null" .line 875 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "scheduler is null" .line 876 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 877 new-instance v0, Lio/reactivex/internal/operators/single/SingleTimer; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/single/SingleTimer;->(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method private static toSingle(Lio/reactivex/Flowable;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/Flowable<", "TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .line 3097 new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableSingleSingle; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/internal/operators/flowable/FlowableSingleSingle;->(Lorg/reactivestreams/Publisher;Ljava/lang/Object;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static unsafeCreate(Lio/reactivex/SingleSource;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onSubscribe is null" .line 918 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 919 instance-of v0, p0, Lio/reactivex/Single; if-nez v0, :cond_0 .line 922 new-instance v0, Lio/reactivex/internal/operators/single/SingleFromUnsafeSource; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleFromUnsafeSource;->(Lio/reactivex/SingleSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .line 920 :cond_0 new-instance p0, Ljava/lang/IllegalArgumentException; const-string v0, "unsafeCreate(Single) should be upgraded" invoke-direct {p0, v0}, Ljava/lang/IllegalArgumentException;->(Ljava/lang/String;)V throw p0 .end method .method public static using(Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "TU;>;", "Lio/reactivex/functions/Function<", "-TU;+", "Lio/reactivex/SingleSource<", "+TT;>;>;", "Lio/reactivex/functions/Consumer<", "-TU;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x1 .line 949 invoke-static {p0, p1, p2, v0}, Lio/reactivex/Single;->using(Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;Z)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static using(Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;Z)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "TU;>;", "Lio/reactivex/functions/Function<", "-TU;+", "Lio/reactivex/SingleSource<", "+TT;>;>;", "Lio/reactivex/functions/Consumer<", "-TU;>;Z)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "resourceSupplier is null" .line 981 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "singleFunction is null" .line 982 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "disposer is null" .line 983 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 985 new-instance v0, Lio/reactivex/internal/operators/single/SingleUsing; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/single/SingleUsing;->(Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;Z)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static wrap(Lio/reactivex/SingleSource;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source is null" .line 1002 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1003 instance-of v0, p0, Lio/reactivex/Single; if-eqz v0, :cond_0 .line 1004 check-cast p0, Lio/reactivex/Single; invoke-static {p0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .line 1006 :cond_0 new-instance v0, Lio/reactivex/internal/operators/single/SingleFromUnsafeSource; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleFromUnsafeSource;->(Lio/reactivex/SingleSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/Function9;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT1;>;", "Lio/reactivex/SingleSource<", "+TT2;>;", "Lio/reactivex/SingleSource<", "+TT3;>;", "Lio/reactivex/SingleSource<", "+TT4;>;", "Lio/reactivex/SingleSource<", "+TT5;>;", "Lio/reactivex/SingleSource<", "+TT6;>;", "Lio/reactivex/SingleSource<", "+TT7;>;", "Lio/reactivex/SingleSource<", "+TT8;>;", "Lio/reactivex/SingleSource<", "+TT9;>;", "Lio/reactivex/functions/Function9<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;-TT9;+TR;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1438 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 1439 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 1440 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 1441 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 1442 invoke-static {p4, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source6 is null" .line 1443 invoke-static {p5, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source7 is null" .line 1444 invoke-static {p6, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source8 is null" .line 1445 invoke-static {p7, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source9 is null" .line 1446 invoke-static {p8, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1447 invoke-static {p9}, Lio/reactivex/internal/functions/Functions;->toFunction(Lio/reactivex/functions/Function9;)Lio/reactivex/functions/Function; move-result-object p9 const/16 v0, 0x9 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 const/4 p0, 0x4 aput-object p4, v0, p0 const/4 p0, 0x5 aput-object p5, v0, p0 const/4 p0, 0x6 aput-object p6, v0, p0 const/4 p0, 0x7 aput-object p7, v0, p0 const/16 p0, 0x8 aput-object p8, v0, p0 invoke-static {p9, v0}, Lio/reactivex/Single;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/Function8;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT1;>;", "Lio/reactivex/SingleSource<", "+TT2;>;", "Lio/reactivex/SingleSource<", "+TT3;>;", "Lio/reactivex/SingleSource<", "+TT4;>;", "Lio/reactivex/SingleSource<", "+TT5;>;", "Lio/reactivex/SingleSource<", "+TT6;>;", "Lio/reactivex/SingleSource<", "+TT7;>;", "Lio/reactivex/SingleSource<", "+TT8;>;", "Lio/reactivex/functions/Function8<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;+TR;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1372 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 1373 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 1374 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 1375 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 1376 invoke-static {p4, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source6 is null" .line 1377 invoke-static {p5, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source7 is null" .line 1378 invoke-static {p6, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source8 is null" .line 1379 invoke-static {p7, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1380 invoke-static {p8}, Lio/reactivex/internal/functions/Functions;->toFunction(Lio/reactivex/functions/Function8;)Lio/reactivex/functions/Function; move-result-object p8 const/16 v0, 0x8 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 const/4 p0, 0x4 aput-object p4, v0, p0 const/4 p0, 0x5 aput-object p5, v0, p0 const/4 p0, 0x6 aput-object p6, v0, p0 const/4 p0, 0x7 aput-object p7, v0, p0 invoke-static {p8, v0}, Lio/reactivex/Single;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/Function7;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT1;>;", "Lio/reactivex/SingleSource<", "+TT2;>;", "Lio/reactivex/SingleSource<", "+TT3;>;", "Lio/reactivex/SingleSource<", "+TT4;>;", "Lio/reactivex/SingleSource<", "+TT5;>;", "Lio/reactivex/SingleSource<", "+TT6;>;", "Lio/reactivex/SingleSource<", "+TT7;>;", "Lio/reactivex/functions/Function7<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;+TR;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1311 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 1312 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 1313 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 1314 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 1315 invoke-static {p4, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source6 is null" .line 1316 invoke-static {p5, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source7 is null" .line 1317 invoke-static {p6, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1318 invoke-static {p7}, Lio/reactivex/internal/functions/Functions;->toFunction(Lio/reactivex/functions/Function7;)Lio/reactivex/functions/Function; move-result-object p7 const/4 v0, 0x7 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 const/4 p0, 0x4 aput-object p4, v0, p0 const/4 p0, 0x5 aput-object p5, v0, p0 const/4 p0, 0x6 aput-object p6, v0, p0 invoke-static {p7, v0}, Lio/reactivex/Single;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/Function6;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT1;>;", "Lio/reactivex/SingleSource<", "+TT2;>;", "Lio/reactivex/SingleSource<", "+TT3;>;", "Lio/reactivex/SingleSource<", "+TT4;>;", "Lio/reactivex/SingleSource<", "+TT5;>;", "Lio/reactivex/SingleSource<", "+TT6;>;", "Lio/reactivex/functions/Function6<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;+TR;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1254 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 1255 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 1256 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 1257 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 1258 invoke-static {p4, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source6 is null" .line 1259 invoke-static {p5, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1260 invoke-static {p6}, Lio/reactivex/internal/functions/Functions;->toFunction(Lio/reactivex/functions/Function6;)Lio/reactivex/functions/Function; move-result-object p6 const/4 v0, 0x6 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 const/4 p0, 0x4 aput-object p4, v0, p0 const/4 p0, 0x5 aput-object p5, v0, p0 invoke-static {p6, v0}, Lio/reactivex/Single;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/Function5;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT1;>;", "Lio/reactivex/SingleSource<", "+TT2;>;", "Lio/reactivex/SingleSource<", "+TT3;>;", "Lio/reactivex/SingleSource<", "+TT4;>;", "Lio/reactivex/SingleSource<", "+TT5;>;", "Lio/reactivex/functions/Function5<", "-TT1;-TT2;-TT3;-TT4;-TT5;+TR;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1202 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 1203 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 1204 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 1205 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 1206 invoke-static {p4, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1207 invoke-static {p5}, Lio/reactivex/internal/functions/Functions;->toFunction(Lio/reactivex/functions/Function5;)Lio/reactivex/functions/Function; move-result-object p5 const/4 v0, 0x5 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 const/4 p0, 0x4 aput-object p4, v0, p0 invoke-static {p5, v0}, Lio/reactivex/Single;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/Function4;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT1;>;", "Lio/reactivex/SingleSource<", "+TT2;>;", "Lio/reactivex/SingleSource<", "+TT3;>;", "Lio/reactivex/SingleSource<", "+TT4;>;", "Lio/reactivex/functions/Function4<", "-TT1;-TT2;-TT3;-TT4;+TR;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1154 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 1155 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 1156 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 1157 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1158 invoke-static {p4}, Lio/reactivex/internal/functions/Functions;->toFunction(Lio/reactivex/functions/Function4;)Lio/reactivex/functions/Function; move-result-object p4 const/4 v0, 0x4 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 invoke-static {p4, v0}, Lio/reactivex/Single;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/Function3;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT1;>;", "Lio/reactivex/SingleSource<", "+TT2;>;", "Lio/reactivex/SingleSource<", "+TT3;>;", "Lio/reactivex/functions/Function3<", "-TT1;-TT2;-TT3;+TR;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1111 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 1112 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 1113 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1114 invoke-static {p3}, Lio/reactivex/internal/functions/Functions;->toFunction(Lio/reactivex/functions/Function3;)Lio/reactivex/functions/Function; move-result-object p3 const/4 v0, 0x3 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 invoke-static {p3, v0}, Lio/reactivex/Single;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/BiFunction;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT1;>;", "Lio/reactivex/SingleSource<", "+TT2;>;", "Lio/reactivex/functions/BiFunction<", "-TT1;-TT2;+TR;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1072 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 1073 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1074 invoke-static {p2}, Lio/reactivex/internal/functions/Functions;->toFunction(Lio/reactivex/functions/BiFunction;)Lio/reactivex/functions/Function; move-result-object p2 const/4 v0, 0x2 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 invoke-static {p2, v0}, Lio/reactivex/Single;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static zip(Ljava/lang/Iterable;Lio/reactivex/functions/Function;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lio/reactivex/SingleSource<", "+TT;>;>;", "Lio/reactivex/functions/Function<", "-[", "Ljava/lang/Object;", "+TR;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1038 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1039 invoke-static {p0}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->iterableToFlowable(Ljava/lang/Iterable;)Ljava/lang/Iterable; move-result-object p0 const/4 v0, 0x0 const/4 v1, 0x1 invoke-static {p0, p1, v0, v1}, Lio/reactivex/Flowable;->zipIterable(Ljava/lang/Iterable;Lio/reactivex/functions/Function;ZI)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->toSingle(Lio/reactivex/Flowable;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static varargs zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single; .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-[", "Ljava/lang/Object;", "+TR;>;[", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1480 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1481 array-length v0, p1 new-array v0, v0, [Lorg/reactivestreams/Publisher; .line 1483 array-length v1, p1 const/4 v2, 0x0 const/4 v3, 0x0 const/4 v4, 0x0 :goto_0 const/4 v5, 0x1 if-ge v3, v1, :cond_0 aget-object v6, p1, v3 .line 1484 new-instance v7, Ljava/lang/StringBuilder; invoke-direct {v7}, Ljava/lang/StringBuilder;->()V const-string v8, "The " invoke-virtual {v7, v8}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v7, v4}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; const-string v8, "th source is null" invoke-virtual {v7, v8}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v7}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v7 invoke-static {v6, v7}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1485 new-instance v7, Lio/reactivex/internal/operators/single/SingleToFlowable; invoke-direct {v7, v6}, Lio/reactivex/internal/operators/single/SingleToFlowable;->(Lio/reactivex/SingleSource;)V invoke-static {v7}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Flowable;)Lio/reactivex/Flowable; move-result-object v6 aput-object v6, v0, v4 add-int/2addr v4, v5 add-int/lit8 v3, v3, 0x1 goto :goto_0 .line 1488 :cond_0 invoke-static {p0, v2, v5, v0}, Lio/reactivex/Flowable;->zipArray(Lio/reactivex/functions/Function;ZI[Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Single;->toSingle(Lio/reactivex/Flowable;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method # virtual methods .method public final ambWith(Lio/reactivex/SingleSource;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1505 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 .line 1506 new-array v0, v0, [Lio/reactivex/SingleSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 v1, 0x1 aput-object p1, v0, v1 invoke-static {v0}, Lio/reactivex/Single;->ambArray([Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final blockingGet()Ljava/lang/Object; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()TT;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2118 new-instance v0, Lio/reactivex/internal/observers/BlockingMultiObserver; invoke-direct {v0}, Lio/reactivex/internal/observers/BlockingMultiObserver;->()V .line 2119 invoke-virtual {p0, v0}, Lio/reactivex/Single;->subscribe(Lio/reactivex/SingleObserver;)V .line 2120 invoke-virtual {v0}, Lio/reactivex/internal/observers/BlockingMultiObserver;->blockingGet()Ljava/lang/Object; move-result-object v0 return-object v0 .end method .method public final cache()Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1565 new-instance v0, Lio/reactivex/internal/operators/single/SingleCache; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleCache;->(Lio/reactivex/SingleSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object v0 return-object v0 .end method .method public final cast(Ljava/lang/Class;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Class<", "+TU;>;)", "Lio/reactivex/Single<", "TU;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "clazz is null" .line 1583 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1584 invoke-static {p1}, Lio/reactivex/internal/functions/Functions;->castFunction(Ljava/lang/Class;)Lio/reactivex/functions/Function; move-result-object p1 invoke-virtual {p0, p1}, Lio/reactivex/Single;->map(Lio/reactivex/functions/Function;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final compose(Lio/reactivex/SingleTransformer;)Lio/reactivex/Single; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleTransformer<", "-TT;+TR;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1547 invoke-interface {p1, p0}, Lio/reactivex/SingleTransformer;->apply(Lio/reactivex/Single;)Lio/reactivex/SingleSource; move-result-object p1 invoke-static {p1}, Lio/reactivex/Single;->wrap(Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final concatWith(Lio/reactivex/SingleSource;)Lio/reactivex/Flowable; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1609 invoke-static {p0, p1}, Lio/reactivex/Single;->concat(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable; move-result-object p1 return-object p1 .end method .method public final contains(Ljava/lang/Object;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Object;", ")", "Lio/reactivex/Single<", "Ljava/lang/Boolean;", ">;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2189 invoke-static {}, Lio/reactivex/internal/functions/ObjectHelper;->equalsPredicate()Lio/reactivex/functions/BiPredicate; move-result-object v0 invoke-virtual {p0, p1, v0}, Lio/reactivex/Single;->contains(Ljava/lang/Object;Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final contains(Ljava/lang/Object;Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Object;", "Lio/reactivex/functions/BiPredicate<", "Ljava/lang/Object;", "Ljava/lang/Object;", ">;)", "Lio/reactivex/Single<", "Ljava/lang/Boolean;", ">;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "value is null" .line 2208 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "comparer is null" .line 2209 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2210 new-instance v0, Lio/reactivex/internal/operators/single/SingleContains; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/single/SingleContains;->(Lio/reactivex/SingleSource;Ljava/lang/Object;Lio/reactivex/functions/BiPredicate;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final delay(JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1628 invoke-static {}, Lio/reactivex/schedulers/Schedulers;->computation()Lio/reactivex/Scheduler; move-result-object v0 invoke-virtual {p0, p1, p2, p3, v0}, Lio/reactivex/Single;->delay(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final delay(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "unit is null" .line 1648 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "scheduler is null" .line 1649 invoke-static {p4, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1650 new-instance v0, Lio/reactivex/internal/operators/single/SingleDelay; move-object v1, v0 move-object v2, p0 move-wide v3, p1 move-object v5, p3 move-object v6, p4 invoke-direct/range {v1 .. v6}, Lio/reactivex/internal/operators/single/SingleDelay;->(Lio/reactivex/SingleSource;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final delaySubscription(JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1757 invoke-static {}, Lio/reactivex/schedulers/Schedulers;->computation()Lio/reactivex/Scheduler; move-result-object v0 invoke-virtual {p0, p1, p2, p3, v0}, Lio/reactivex/Single;->delaySubscription(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final delaySubscription(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation .line 1777 invoke-static {p1, p2, p3, p4}, Lio/reactivex/Observable;->timer(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Observable; move-result-object p1 invoke-virtual {p0, p1}, Lio/reactivex/Single;->delaySubscription(Lio/reactivex/ObservableSource;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final delaySubscription(Lio/reactivex/CompletableSource;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/CompletableSource;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1670 new-instance v0, Lio/reactivex/internal/operators/single/SingleDelayWithCompletable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDelayWithCompletable;->(Lio/reactivex/SingleSource;Lio/reactivex/CompletableSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final delaySubscription(Lio/reactivex/ObservableSource;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/ObservableSource<", "TU;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1712 new-instance v0, Lio/reactivex/internal/operators/single/SingleDelayWithObservable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDelayWithObservable;->(Lio/reactivex/SingleSource;Lio/reactivex/ObservableSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final delaySubscription(Lio/reactivex/SingleSource;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "TU;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1691 new-instance v0, Lio/reactivex/internal/operators/single/SingleDelayWithSingle; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDelayWithSingle;->(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final delaySubscription(Lorg/reactivestreams/Publisher;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "TU;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1738 new-instance v0, Lio/reactivex/internal/operators/single/SingleDelayWithPublisher; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDelayWithPublisher;->(Lio/reactivex/SingleSource;Lorg/reactivestreams/Publisher;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final doAfterSuccess(Lio/reactivex/functions/Consumer;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Consumer<", "-TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/Experimental; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "doAfterSuccess is null" .line 1796 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1797 new-instance v0, Lio/reactivex/internal/operators/single/SingleDoAfterSuccess; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDoAfterSuccess;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Consumer;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final doFinally(Lio/reactivex/functions/Action;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Action;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/Experimental; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onFinally is null" .line 1819 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1820 new-instance v0, Lio/reactivex/internal/operators/single/SingleDoFinally; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDoFinally;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Action;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final doOnDispose(Lio/reactivex/functions/Action;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Action;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onDispose is null" .line 1909 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1910 new-instance v0, Lio/reactivex/internal/operators/single/SingleDoOnDispose; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDoOnDispose;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Action;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final doOnError(Lio/reactivex/functions/Consumer;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Consumer<", "-", "Ljava/lang/Throwable;", ">;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onError is null" .line 1891 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1892 new-instance v0, Lio/reactivex/internal/operators/single/SingleDoOnError; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDoOnError;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Consumer;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final doOnEvent(Lio/reactivex/functions/BiConsumer;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/BiConsumer<", "-TT;-", "Ljava/lang/Throwable;", ">;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onEvent is null" .line 1873 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1874 new-instance v0, Lio/reactivex/internal/operators/single/SingleDoOnEvent; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDoOnEvent;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/BiConsumer;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final doOnSubscribe(Lio/reactivex/functions/Consumer;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Consumer<", "-", "Lio/reactivex/disposables/Disposable;", ">;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onSubscribe is null" .line 1837 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1838 new-instance v0, Lio/reactivex/internal/operators/single/SingleDoOnSubscribe; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDoOnSubscribe;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Consumer;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final doOnSuccess(Lio/reactivex/functions/Consumer;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Consumer<", "-TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onSuccess is null" .line 1855 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1856 new-instance v0, Lio/reactivex/internal/operators/single/SingleDoOnSuccess; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDoOnSuccess;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Consumer;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final filter(Lio/reactivex/functions/Predicate;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Predicate<", "-TT;>;)", "Lio/reactivex/Maybe<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "predicate is null" .line 1933 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1934 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFilterSingle; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFilterSingle;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Predicate;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final flatMap(Lio/reactivex/functions/Function;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-TT;+", "Lio/reactivex/SingleSource<", "+TR;>;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1956 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1957 new-instance v0, Lio/reactivex/internal/operators/single/SingleFlatMap; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleFlatMap;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final flatMapCompletable(Lio/reactivex/functions/Function;)Lio/reactivex/Completable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-TT;+", "Lio/reactivex/CompletableSource;", ">;)", "Lio/reactivex/Completable;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 2102 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2103 new-instance v0, Lio/reactivex/internal/operators/single/SingleFlatMapCompletable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleFlatMapCompletable;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Completable;)Lio/reactivex/Completable; move-result-object p1 return-object p1 .end method .method public final flatMapMaybe(Lio/reactivex/functions/Function;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-TT;+", "Lio/reactivex/MaybeSource<", "+TR;>;>;)", "Lio/reactivex/Maybe<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1979 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1980 new-instance v0, Lio/reactivex/internal/operators/single/SingleFlatMapMaybe; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleFlatMapMaybe;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final flatMapObservable(Lio/reactivex/functions/Function;)Lio/reactivex/Observable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-TT;+", "Lio/reactivex/ObservableSource<", "+TR;>;>;)", "Lio/reactivex/Observable<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2079 invoke-virtual {p0}, Lio/reactivex/Single;->toObservable()Lio/reactivex/Observable; move-result-object v0 invoke-virtual {v0, p1}, Lio/reactivex/Observable;->flatMap(Lio/reactivex/functions/Function;)Lio/reactivex/Observable; move-result-object p1 return-object p1 .end method .method public final flatMapPublisher(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-TT;+", "Lorg/reactivestreams/Publisher<", "+TR;>;>;)", "Lio/reactivex/Flowable<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2007 invoke-virtual {p0}, Lio/reactivex/Single;->toFlowable()Lio/reactivex/Flowable; move-result-object v0 invoke-virtual {v0, p1}, Lio/reactivex/Flowable;->flatMap(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable; move-result-object p1 return-object p1 .end method .method public final flattenAsFlowable(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-TT;+", "Ljava/lang/Iterable<", "+TU;>;>;)", "Lio/reactivex/Flowable<", "TU;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2034 new-instance v0, Lio/reactivex/internal/operators/single/SingleFlatMapIterableFlowable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleFlatMapIterableFlowable;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Flowable;)Lio/reactivex/Flowable; move-result-object p1 return-object p1 .end method .method public final flattenAsObservable(Lio/reactivex/functions/Function;)Lio/reactivex/Observable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-TT;+", "Ljava/lang/Iterable<", "+TU;>;>;)", "Lio/reactivex/Observable<", "TU;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2057 new-instance v0, Lio/reactivex/internal/operators/single/SingleFlatMapIterableObservable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleFlatMapIterableObservable;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Observable;)Lio/reactivex/Observable; move-result-object p1 return-object p1 .end method .method public final hide()Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1522 new-instance v0, Lio/reactivex/internal/operators/single/SingleHide; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleHide;->(Lio/reactivex/SingleSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object v0 return-object v0 .end method .method public final lift(Lio/reactivex/SingleOperator;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleOperator<", "+TR;-TT;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onLift is null" .line 2149 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2150 new-instance v0, Lio/reactivex/internal/operators/single/SingleLift; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleLift;->(Lio/reactivex/SingleSource;Lio/reactivex/SingleOperator;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final map(Lio/reactivex/functions/Function;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-TT;+TR;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2172 new-instance v0, Lio/reactivex/internal/operators/single/SingleMap; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleMap;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final mergeWith(Lio/reactivex/SingleSource;)Lio/reactivex/Flowable; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2236 invoke-static {p0, p1}, Lio/reactivex/Single;->merge(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable; move-result-object p1 return-object p1 .end method .method public final observeOn(Lio/reactivex/Scheduler;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "scheduler is null" .line 2260 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2261 new-instance v0, Lio/reactivex/internal/operators/single/SingleObserveOn; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleObserveOn;->(Lio/reactivex/SingleSource;Lio/reactivex/Scheduler;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final onErrorResumeNext(Lio/reactivex/Single;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/Single<", "+TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "resumeSingleInCaseOfError is null" .line 2344 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2345 invoke-static {p1}, Lio/reactivex/internal/functions/Functions;->justFunction(Ljava/lang/Object;)Lio/reactivex/functions/Function; move-result-object p1 invoke-virtual {p0, p1}, Lio/reactivex/Single;->onErrorResumeNext(Lio/reactivex/functions/Function;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final onErrorResumeNext(Lio/reactivex/functions/Function;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-", "Ljava/lang/Throwable;", "+", "Lio/reactivex/SingleSource<", "+TT;>;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "resumeFunctionInCaseOfError is null" .line 2380 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2381 new-instance v0, Lio/reactivex/internal/operators/single/SingleResumeNext; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleResumeNext;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final onErrorReturn(Lio/reactivex/functions/Function;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "Ljava/lang/Throwable;", "+TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "resumeFunction is null" .line 2293 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2294 new-instance v0, Lio/reactivex/internal/operators/single/SingleOnErrorReturn; const/4 v1, 0x0 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/internal/operators/single/SingleOnErrorReturn;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;Ljava/lang/Object;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final onErrorReturnItem(Ljava/lang/Object;)Lio/reactivex/Single; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(TT;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "value is null" .line 2310 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2311 new-instance v0, Lio/reactivex/internal/operators/single/SingleOnErrorReturn; const/4 v1, 0x0 invoke-direct {v0, p0, v1, p1}, Lio/reactivex/internal/operators/single/SingleOnErrorReturn;->(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;Ljava/lang/Object;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final repeat()Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2399 invoke-virtual {p0}, Lio/reactivex/Single;->toFlowable()Lio/reactivex/Flowable; move-result-object v0 invoke-virtual {v0}, Lio/reactivex/Flowable;->repeat()Lio/reactivex/Flowable; move-result-object v0 return-object v0 .end method .method public final repeat(J)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2418 invoke-virtual {p0}, Lio/reactivex/Single;->toFlowable()Lio/reactivex/Flowable; move-result-object v0 invoke-virtual {v0, p1, p2}, Lio/reactivex/Flowable;->repeat(J)Lio/reactivex/Flowable; move-result-object p1 return-object p1 .end method .method public final repeatUntil(Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/BooleanSupplier;", ")", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2463 invoke-virtual {p0}, Lio/reactivex/Single;->toFlowable()Lio/reactivex/Flowable; move-result-object v0 invoke-virtual {v0, p1}, Lio/reactivex/Flowable;->repeatUntil(Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/Flowable; move-result-object p1 return-object p1 .end method .method public final repeatWhen(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-", "Lio/reactivex/Flowable<", "Ljava/lang/Object;", ">;+", "Lorg/reactivestreams/Publisher<", "Ljava/lang/Object;", ">;>;)", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2443 invoke-virtual {p0}, Lio/reactivex/Single;->toFlowable()Lio/reactivex/Flowable; move-result-object v0 invoke-virtual {v0, p1}, Lio/reactivex/Flowable;->repeatWhen(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable; move-result-object p1 return-object p1 .end method .method public final retry()Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2478 invoke-virtual {p0}, Lio/reactivex/Single;->toFlowable()Lio/reactivex/Flowable; move-result-object v0 invoke-virtual {v0}, Lio/reactivex/Flowable;->retry()Lio/reactivex/Flowable; move-result-object v0 invoke-static {v0}, Lio/reactivex/Single;->toSingle(Lio/reactivex/Flowable;)Lio/reactivex/Single; move-result-object v0 return-object v0 .end method .method public final retry(J)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2495 invoke-virtual {p0}, Lio/reactivex/Single;->toFlowable()Lio/reactivex/Flowable; move-result-object v0 invoke-virtual {v0, p1, p2}, Lio/reactivex/Flowable;->retry(J)Lio/reactivex/Flowable; move-result-object p1 invoke-static {p1}, Lio/reactivex/Single;->toSingle(Lio/reactivex/Flowable;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final retry(Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/BiPredicate<", "-", "Ljava/lang/Integer;", "-", "Ljava/lang/Throwable;", ">;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2513 invoke-virtual {p0}, Lio/reactivex/Single;->toFlowable()Lio/reactivex/Flowable; move-result-object v0 invoke-virtual {v0, p1}, Lio/reactivex/Flowable;->retry(Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Flowable; move-result-object p1 invoke-static {p1}, Lio/reactivex/Single;->toSingle(Lio/reactivex/Flowable;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final retry(Lio/reactivex/functions/Predicate;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Predicate<", "-", "Ljava/lang/Throwable;", ">;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2531 invoke-virtual {p0}, Lio/reactivex/Single;->toFlowable()Lio/reactivex/Flowable; move-result-object v0 invoke-virtual {v0, p1}, Lio/reactivex/Flowable;->retry(Lio/reactivex/functions/Predicate;)Lio/reactivex/Flowable; move-result-object p1 invoke-static {p1}, Lio/reactivex/Single;->toSingle(Lio/reactivex/Flowable;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final retryWhen(Lio/reactivex/functions/Function;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-", "Lio/reactivex/Flowable<", "Ljava/lang/Throwable;", ">;+", "Lorg/reactivestreams/Publisher<", "Ljava/lang/Object;", ">;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2553 invoke-virtual {p0}, Lio/reactivex/Single;->toFlowable()Lio/reactivex/Flowable; move-result-object v0 invoke-virtual {v0, p1}, Lio/reactivex/Flowable;->retryWhen(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable; move-result-object p1 invoke-static {p1}, Lio/reactivex/Single;->toSingle(Lio/reactivex/Flowable;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final subscribe()Lio/reactivex/disposables/Disposable; .locals 2 .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2568 invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v0 sget-object v1, Lio/reactivex/internal/functions/Functions;->ERROR_CONSUMER:Lio/reactivex/functions/Consumer; invoke-virtual {p0, v0, v1}, Lio/reactivex/Single;->subscribe(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable; move-result-object v0 return-object v0 .end method .method public final subscribe(Lio/reactivex/functions/BiConsumer;)Lio/reactivex/disposables/Disposable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/BiConsumer<", "-TT;-", "Ljava/lang/Throwable;", ">;)", "Lio/reactivex/disposables/Disposable;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onCallback is null" .line 2590 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2592 new-instance v0, Lio/reactivex/internal/observers/BiConsumerSingleObserver; invoke-direct {v0, p1}, Lio/reactivex/internal/observers/BiConsumerSingleObserver;->(Lio/reactivex/functions/BiConsumer;)V .line 2593 invoke-virtual {p0, v0}, Lio/reactivex/Single;->subscribe(Lio/reactivex/SingleObserver;)V return-object v0 .end method .method public final subscribe(Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Consumer<", "-TT;>;)", "Lio/reactivex/disposables/Disposable;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2614 sget-object v0, Lio/reactivex/internal/functions/Functions;->ERROR_CONSUMER:Lio/reactivex/functions/Consumer; invoke-virtual {p0, p1, v0}, Lio/reactivex/Single;->subscribe(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable; move-result-object p1 return-object p1 .end method .method public final subscribe(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Consumer<", "-TT;>;", "Lio/reactivex/functions/Consumer<", "-", "Ljava/lang/Throwable;", ">;)", "Lio/reactivex/disposables/Disposable;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onSuccess is null" .line 2639 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onError is null" .line 2640 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2642 new-instance v0, Lio/reactivex/internal/observers/ConsumerSingleObserver; invoke-direct {v0, p1, p2}, Lio/reactivex/internal/observers/ConsumerSingleObserver;->(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;)V .line 2643 invoke-virtual {p0, v0}, Lio/reactivex/Single;->subscribe(Lio/reactivex/SingleObserver;)V return-object v0 .end method .method public final subscribe(Lio/reactivex/SingleObserver;)V .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleObserver<", "-TT;>;)V" } .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "subscriber is null" .line 2650 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2652 invoke-static {p0, p1}, Lio/reactivex/plugins/RxJavaPlugins;->onSubscribe(Lio/reactivex/Single;Lio/reactivex/SingleObserver;)Lio/reactivex/SingleObserver; move-result-object p1 const-string v0, "subscriber returned by the RxJavaPlugins hook is null" .line 2654 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2657 :try_start_0 invoke-virtual {p0, p1}, Lio/reactivex/Single;->subscribeActual(Lio/reactivex/SingleObserver;)V :try_end_0 .catch Ljava/lang/NullPointerException; {:try_start_0 .. :try_end_0} :catch_1 .catch Ljava/lang/Throwable; {:try_start_0 .. :try_end_0} :catch_0 return-void :catch_0 move-exception p1 .line 2661 invoke-static {p1}, Lio/reactivex/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V .line 2662 new-instance v0, Ljava/lang/NullPointerException; const-string v1, "subscribeActual failed" invoke-direct {v0, v1}, Ljava/lang/NullPointerException;->(Ljava/lang/String;)V .line 2663 invoke-virtual {v0, p1}, Ljava/lang/NullPointerException;->initCause(Ljava/lang/Throwable;)Ljava/lang/Throwable; .line 2664 throw v0 :catch_1 move-exception p1 .line 2659 throw p1 .end method .method protected abstract subscribeActual(Lio/reactivex/SingleObserver;)V .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleObserver<", "-TT;>;)V" } .end annotation .end method .method public final subscribeOn(Lio/reactivex/Scheduler;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "scheduler is null" .line 2724 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2725 new-instance v0, Lio/reactivex/internal/operators/single/SingleSubscribeOn; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleSubscribeOn;->(Lio/reactivex/SingleSource;Lio/reactivex/Scheduler;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final subscribeWith(Lio/reactivex/SingleObserver;)Lio/reactivex/SingleObserver; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { ";>(TE;)TE;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2701 invoke-virtual {p0, p1}, Lio/reactivex/Single;->subscribe(Lio/reactivex/SingleObserver;)V return-object p1 .end method .method public final takeUntil(Lio/reactivex/CompletableSource;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/CompletableSource;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2748 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableToFlowable; invoke-direct {v0, p1}, Lio/reactivex/internal/operators/completable/CompletableToFlowable;->(Lio/reactivex/CompletableSource;)V invoke-virtual {p0, v0}, Lio/reactivex/Single;->takeUntil(Lorg/reactivestreams/Publisher;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final takeUntil(Lio/reactivex/SingleSource;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "+TE;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2802 new-instance v0, Lio/reactivex/internal/operators/single/SingleToFlowable; invoke-direct {v0, p1}, Lio/reactivex/internal/operators/single/SingleToFlowable;->(Lio/reactivex/SingleSource;)V invoke-virtual {p0, v0}, Lio/reactivex/Single;->takeUntil(Lorg/reactivestreams/Publisher;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final takeUntil(Lorg/reactivestreams/Publisher;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "TE;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2778 new-instance v0, Lio/reactivex/internal/operators/single/SingleTakeUntil; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleTakeUntil;->(Lio/reactivex/SingleSource;Lorg/reactivestreams/Publisher;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final test()Lio/reactivex/observers/TestObserver; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/observers/TestObserver<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 3067 new-instance v0, Lio/reactivex/observers/TestObserver; invoke-direct {v0}, Lio/reactivex/observers/TestObserver;->()V .line 3068 invoke-virtual {p0, v0}, Lio/reactivex/Single;->subscribe(Lio/reactivex/SingleObserver;)V return-object v0 .end method .method public final test(Z)Lio/reactivex/observers/TestObserver; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(Z)", "Lio/reactivex/observers/TestObserver<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 3086 new-instance v0, Lio/reactivex/observers/TestObserver; invoke-direct {v0}, Lio/reactivex/observers/TestObserver;->()V if-eqz p1, :cond_0 .line 3089 invoke-virtual {v0}, Lio/reactivex/observers/TestObserver;->cancel()V .line 3092 :cond_0 invoke-virtual {p0, v0}, Lio/reactivex/Single;->subscribe(Lio/reactivex/SingleObserver;)V return-object v0 .end method .method public final timeout(JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single; .locals 6 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 2820 invoke-static {}, Lio/reactivex/schedulers/Schedulers;->computation()Lio/reactivex/Scheduler; move-result-object v4 const/4 v5, 0x0 move-object v0, p0 move-wide v1, p1 move-object v3, p3 invoke-direct/range {v0 .. v5}, Lio/reactivex/Single;->timeout0(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final timeout(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single; .locals 6 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const/4 v5, 0x0 move-object v0, p0 move-wide v1, p1 move-object v3, p3 move-object v4, p4 .line 2840 invoke-direct/range {v0 .. v5}, Lio/reactivex/Single;->timeout0(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final timeout(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/Scheduler;", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "other is null" .line 2860 invoke-static {p5, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2861 invoke-direct/range {p0 .. p5}, Lio/reactivex/Single;->timeout0(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final timeout(JLjava/util/concurrent/TimeUnit;Lio/reactivex/SingleSource;)Lio/reactivex/Single; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/SingleSource<", "+TT;>;)", "Lio/reactivex/Single<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation const-string v0, "other is null" .line 2881 invoke-static {p4, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2882 invoke-static {}, Lio/reactivex/schedulers/Schedulers;->computation()Lio/reactivex/Scheduler; move-result-object v5 move-object v1, p0 move-wide v2, p1 move-object v4, p3 move-object v6, p4 invoke-direct/range {v1 .. v6}, Lio/reactivex/Single;->timeout0(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method .method public final to(Lio/reactivex/functions/Function;)Ljava/lang/Object; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-", "Lio/reactivex/Single<", "TT;>;TR;>;)TR;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2908 :try_start_0 invoke-interface {p1, p0}, Lio/reactivex/functions/Function;->apply(Ljava/lang/Object;)Ljava/lang/Object; move-result-object p1 :try_end_0 .catch Ljava/lang/Throwable; {:try_start_0 .. :try_end_0} :catch_0 return-object p1 :catch_0 move-exception p1 .line 2910 invoke-static {p1}, Lio/reactivex/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V .line 2911 invoke-static {p1}, Lio/reactivex/internal/util/ExceptionHelper;->wrapOrThrow(Ljava/lang/Throwable;)Ljava/lang/RuntimeException; move-result-object p1 throw p1 .end method .method public final toCompletable()Lio/reactivex/Completable; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2936 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableFromSingle; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/CompletableFromSingle;->(Lio/reactivex/SingleSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Completable;)Lio/reactivex/Completable; move-result-object v0 return-object v0 .end method .method public final toFlowable()Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/Flowable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2957 instance-of v0, p0, Lio/reactivex/internal/fuseable/FuseToFlowable; if-eqz v0, :cond_0 .line 2958 move-object v0, p0 check-cast v0, Lio/reactivex/internal/fuseable/FuseToFlowable; invoke-interface {v0}, Lio/reactivex/internal/fuseable/FuseToFlowable;->fuseToFlowable()Lio/reactivex/Flowable; move-result-object v0 return-object v0 .line 2960 :cond_0 new-instance v0, Lio/reactivex/internal/operators/single/SingleToFlowable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleToFlowable;->(Lio/reactivex/SingleSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Flowable;)Lio/reactivex/Flowable; move-result-object v0 return-object v0 .end method .method public final toFuture()Ljava/util/concurrent/Future; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Ljava/util/concurrent/Future<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2978 new-instance v0, Lio/reactivex/internal/observers/FutureSingleObserver; invoke-direct {v0}, Lio/reactivex/internal/observers/FutureSingleObserver;->()V invoke-virtual {p0, v0}, Lio/reactivex/Single;->subscribeWith(Lio/reactivex/SingleObserver;)Lio/reactivex/SingleObserver; move-result-object v0 check-cast v0, Ljava/util/concurrent/Future; return-object v0 .end method .method public final toMaybe()Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/Maybe<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2996 instance-of v0, p0, Lio/reactivex/internal/fuseable/FuseToMaybe; if-eqz v0, :cond_0 .line 2997 move-object v0, p0 check-cast v0, Lio/reactivex/internal/fuseable/FuseToMaybe; invoke-interface {v0}, Lio/reactivex/internal/fuseable/FuseToMaybe;->fuseToMaybe()Lio/reactivex/Maybe; move-result-object v0 return-object v0 .line 2999 :cond_0 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFromSingle; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeFromSingle;->(Lio/reactivex/SingleSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object v0 return-object v0 .end method .method public final toObservable()Lio/reactivex/Observable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/Observable<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 3016 instance-of v0, p0, Lio/reactivex/internal/fuseable/FuseToObservable; if-eqz v0, :cond_0 .line 3017 move-object v0, p0 check-cast v0, Lio/reactivex/internal/fuseable/FuseToObservable; invoke-interface {v0}, Lio/reactivex/internal/fuseable/FuseToObservable;->fuseToObservable()Lio/reactivex/Observable; move-result-object v0 return-object v0 .line 3019 :cond_0 new-instance v0, Lio/reactivex/internal/operators/single/SingleToObservable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleToObservable;->(Lio/reactivex/SingleSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Observable;)Lio/reactivex/Observable; move-result-object v0 return-object v0 .end method .method public final zipWith(Lio/reactivex/SingleSource;Lio/reactivex/functions/BiFunction;)Lio/reactivex/Single; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "TU;>;", "Lio/reactivex/functions/BiFunction<", "-TT;-TU;+TR;>;)", "Lio/reactivex/Single<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 3048 invoke-static {p0, p1, p2}, Lio/reactivex/Single;->zip(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/BiFunction;)Lio/reactivex/Single; move-result-object p1 return-object p1 .end method