.class public abstract Lio/reactivex/Maybe; .super Ljava/lang/Object; .source "Maybe.java" # interfaces .implements Lio/reactivex/MaybeSource; # annotations .annotation system Ldalvik/annotation/Signature; value = { "", "Ljava/lang/Object;", "Lio/reactivex/MaybeSource<", "TT;>;" } .end annotation # direct methods .method public constructor ()V .locals 0 .line 47 invoke-direct {p0}, Ljava/lang/Object;->()V return-void .end method .method public static amb(Ljava/lang/Iterable;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lio/reactivex/MaybeSource<", "+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, "sources is null" .line 63 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 64 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeAmb; const/4 v1, 0x0 invoke-direct {v0, v1, p0}, Lio/reactivex/internal/operators/maybe/MaybeAmb;->([Lio/reactivex/MaybeSource;Ljava/lang/Iterable;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static varargs ambArray([Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lio/reactivex/MaybeSource<", "+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 .line 82 array-length v0, p0 if-nez v0, :cond_0 .line 83 invoke-static {}, Lio/reactivex/Maybe;->empty()Lio/reactivex/Maybe; move-result-object p0 return-object p0 .line 85 :cond_0 array-length v0, p0 const/4 v1, 0x1 if-ne v0, v1, :cond_1 const/4 v0, 0x0 .line 86 aget-object p0, p0, v0 invoke-static {p0}, Lio/reactivex/Maybe;->wrap(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .line 88 :cond_1 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeAmb; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/internal/operators/maybe/MaybeAmb;->([Lio/reactivex/MaybeSource;Ljava/lang/Iterable;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static concat(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+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 136 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 137 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 .line 138 new-array v0, v0, [Lio/reactivex/MaybeSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 invoke-static {v0}, Lio/reactivex/Maybe;->concatArray([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static concat(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+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 168 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 169 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 170 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x3 .line 171 new-array v0, v0, [Lio/reactivex/MaybeSource; 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/Maybe;->concatArray([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static concat(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+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 203 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 204 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 205 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 206 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x4 .line 207 new-array v0, v0, [Lio/reactivex/MaybeSource; 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/Maybe;->concatArray([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static concat(Ljava/lang/Iterable;)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lio/reactivex/MaybeSource<", "+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, "sources is null" .line 108 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 109 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeConcatIterable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeConcatIterable;->(Ljava/lang/Iterable;)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(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "+", "Lio/reactivex/MaybeSource<", "+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 229 invoke-static {p0, v0}, Lio/reactivex/Maybe;->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/MaybeSource<", "+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, "sources is null" .line 253 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "prefetch" .line 254 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->verifyPositive(ILjava/lang/String;)I .line 255 new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableConcatMap; invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()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 varargs concatArray([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lio/reactivex/MaybeSource<", "+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, "sources is null" .line 275 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 276 array-length v0, p0 if-nez v0, :cond_0 .line 277 invoke-static {}, Lio/reactivex/Flowable;->empty()Lio/reactivex/Flowable; move-result-object p0 return-object p0 .line 279 :cond_0 array-length v0, p0 const/4 v1, 0x1 if-ne v0, v1, :cond_1 .line 280 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeToFlowable; const/4 v1, 0x0 aget-object p0, p0, v1 invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeToFlowable;->(Lio/reactivex/MaybeSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Flowable;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .line 282 :cond_1 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeConcatArray;->([Lio/reactivex/MaybeSource;)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 varargs concatArrayDelayError([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lio/reactivex/MaybeSource<", "+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 306 array-length v0, p0 if-nez v0, :cond_0 .line 307 invoke-static {}, Lio/reactivex/Flowable;->empty()Lio/reactivex/Flowable; move-result-object p0 return-object p0 .line 309 :cond_0 array-length v0, p0 const/4 v1, 0x1 if-ne v0, v1, :cond_1 .line 310 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeToFlowable; const/4 v1, 0x0 aget-object p0, p0, v1 invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeToFlowable;->(Lio/reactivex/MaybeSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Flowable;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .line 312 :cond_1 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeConcatArrayDelayError; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeConcatArrayDelayError;->([Lio/reactivex/MaybeSource;)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 varargs concatArrayEager([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lio/reactivex/MaybeSource<", "+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 336 invoke-static {p0}, Lio/reactivex/Flowable;->fromArray([Ljava/lang/Object;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lio/reactivex/functions/Function; move-result-object v0 invoke-virtual {p0, v0}, Lio/reactivex/Flowable;->concatMapEager(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static concatDelayError(Ljava/lang/Iterable;)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lio/reactivex/MaybeSource<", "+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, "sources is null" .line 359 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 360 invoke-static {p0}, Lio/reactivex/Flowable;->fromIterable(Ljava/lang/Iterable;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lio/reactivex/functions/Function; move-result-object v0 invoke-virtual {p0, v0}, Lio/reactivex/Flowable;->concatMapDelayError(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static concatDelayError(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "+", "Lio/reactivex/MaybeSource<", "+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 383 invoke-static {p0}, Lio/reactivex/Flowable;->fromPublisher(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lio/reactivex/functions/Function; move-result-object v0 invoke-virtual {p0, v0}, Lio/reactivex/Flowable;->concatMapDelayError(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static concatEager(Ljava/lang/Iterable;)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lio/reactivex/MaybeSource<", "+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 407 invoke-static {p0}, Lio/reactivex/Flowable;->fromIterable(Ljava/lang/Iterable;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lio/reactivex/functions/Function; move-result-object v0 invoke-virtual {p0, v0}, Lio/reactivex/Flowable;->concatMapEager(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static concatEager(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "+", "Lio/reactivex/MaybeSource<", "+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 433 invoke-static {p0}, Lio/reactivex/Flowable;->fromPublisher(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lio/reactivex/functions/Function; move-result-object v0 invoke-virtual {p0, v0}, Lio/reactivex/Flowable;->concatMapEager(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static create(Lio/reactivex/MaybeOnSubscribe;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeOnSubscribe<", "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, "onSubscribe is null" .line 478 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 479 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeCreate; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeCreate;->(Lio/reactivex/MaybeOnSubscribe;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static defer(Ljava/util/concurrent/Callable;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+", "Lio/reactivex/MaybeSource<", "+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, "maybeSupplier is null" .line 497 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 498 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeDefer; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeDefer;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static empty()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 517 sget-object v0, Lio/reactivex/internal/operators/maybe/MaybeEmpty;->INSTANCE:Lio/reactivex/internal/operators/maybe/MaybeEmpty; 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 static error(Ljava/lang/Throwable;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Throwable;", ")", "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, "exception is null" .line 541 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 542 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeError; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeError;->(Ljava/lang/Throwable;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static error(Ljava/util/concurrent/Callable;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+", "Ljava/lang/Throwable;", ">;)", "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, "errorSupplier is null" .line 566 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 567 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeErrorCallable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeErrorCallable;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static fromAction(Lio/reactivex/functions/Action;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Action;", ")", "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, "run is null" .line 585 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 586 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFromAction; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeFromAction;->(Lio/reactivex/functions/Action;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static fromCallable(Ljava/util/concurrent/Callable;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+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, "callable is null" .line 648 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 649 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFromCallable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeFromCallable;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static fromCompletable(Lio/reactivex/CompletableSource;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/CompletableSource;", ")", "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, "completableSource is null" .line 604 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 605 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFromCompletable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeFromCompletable;->(Lio/reactivex/CompletableSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static fromFuture(Ljava/util/concurrent/Future;)Lio/reactivex/Maybe; .locals 4 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "+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, "future is null" .line 681 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 682 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFromFuture; const-wide/16 v1, 0x0 const/4 v3, 0x0 invoke-direct {v0, p0, v1, v2, v3}, Lio/reactivex/internal/operators/maybe/MaybeFromFuture;->(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static fromFuture(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "+TT;>;J", "Ljava/util/concurrent/TimeUnit;", ")", "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, "future is null" .line 718 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "unit is null" .line 719 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 720 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFromFuture; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/maybe/MaybeFromFuture;->(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static fromRunnable(Ljava/lang/Runnable;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Runnable;", ")", "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, "run is null" .line 738 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 739 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFromRunnable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeFromRunnable;->(Ljava/lang/Runnable;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static fromSingle(Lio/reactivex/SingleSource;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/SingleSource<", "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, "singleSource is null" .line 623 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 624 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 p0 return-object p0 .end method .method public static just(Ljava/lang/Object;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(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, "item is null" .line 765 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 766 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeJust; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeJust;->(Ljava/lang/Object;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static merge(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+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 885 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 886 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 .line 887 new-array v0, v0, [Lio/reactivex/MaybeSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 invoke-static {v0}, Lio/reactivex/Maybe;->mergeArray([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static merge(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+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 922 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 923 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 924 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x3 .line 925 new-array v0, v0, [Lio/reactivex/MaybeSource; 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/Maybe;->mergeArray([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static merge(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+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 962 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 963 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 964 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 965 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x4 .line 966 new-array v0, v0, [Lio/reactivex/MaybeSource; 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/Maybe;->mergeArray([Lio/reactivex/MaybeSource;)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/MaybeSource<", "+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 786 invoke-static {p0}, Lio/reactivex/Flowable;->fromIterable(Ljava/lang/Iterable;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {p0}, Lio/reactivex/Maybe;->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 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "+", "Lio/reactivex/MaybeSource<", "+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 v0, 0x7fffffff .line 806 invoke-static {p0, v0}, Lio/reactivex/Maybe;->merge(Lorg/reactivestreams/Publisher;I)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static merge(Lorg/reactivestreams/Publisher;I)Lio/reactivex/Flowable; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "+", "Lio/reactivex/MaybeSource<", "+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 .line 828 new-instance v6, Lio/reactivex/internal/operators/flowable/FlowableFlatMap; invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lio/reactivex/functions/Function; move-result-object v2 invoke-static {}, Lio/reactivex/Flowable;->bufferSize()I move-result v5 const/4 v3, 0x0 move-object v0, v6 move-object v1, p0 move v4, p1 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/MaybeSource;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+", "Lio/reactivex/MaybeSource<", "+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 .line 853 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFlatten; 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/maybe/MaybeFlatten;->(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static varargs mergeArray([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lio/reactivex/MaybeSource<", "+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, "sources is null" .line 987 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 988 array-length v0, p0 if-nez v0, :cond_0 .line 989 invoke-static {}, Lio/reactivex/Flowable;->empty()Lio/reactivex/Flowable; move-result-object p0 return-object p0 .line 991 :cond_0 array-length v0, p0 const/4 v1, 0x1 if-ne v0, v1, :cond_1 .line 992 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeToFlowable; const/4 v1, 0x0 aget-object p0, p0, v1 invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeToFlowable;->(Lio/reactivex/MaybeSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Flowable;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .line 994 :cond_1 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeMergeArray; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeMergeArray;->([Lio/reactivex/MaybeSource;)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 varargs mergeArrayDelayError([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 3 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lio/reactivex/MaybeSource<", "+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 1029 invoke-static {p0}, Lio/reactivex/Flowable;->fromArray([Ljava/lang/Object;)Lio/reactivex/Flowable; move-result-object v0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lio/reactivex/functions/Function; move-result-object v1 array-length p0, p0 const/4 v2, 0x1 invoke-virtual {v0, v1, v2, p0}, Lio/reactivex/Flowable;->flatMap(Lio/reactivex/functions/Function;ZI)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static mergeDelayError(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+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 1138 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 1139 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 .line 1140 new-array v0, v0, [Lio/reactivex/MaybeSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 invoke-static {v0}, Lio/reactivex/Maybe;->mergeArrayDelayError([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static mergeDelayError(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+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 1180 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 1181 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 1182 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x3 .line 1183 new-array v0, v0, [Lio/reactivex/MaybeSource; 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/Maybe;->mergeArrayDelayError([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static mergeDelayError(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+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 1227 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 1228 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 1229 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 1230 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x4 .line 1231 new-array v0, v0, [Lio/reactivex/MaybeSource; 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/Maybe;->mergeArrayDelayError([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static mergeDelayError(Ljava/lang/Iterable;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lio/reactivex/MaybeSource<", "+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 1065 invoke-static {p0}, Lio/reactivex/Flowable;->fromIterable(Ljava/lang/Iterable;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lio/reactivex/functions/Function; move-result-object v0 const/4 v1, 0x1 invoke-virtual {p0, v0, v1}, Lio/reactivex/Flowable;->flatMap(Lio/reactivex/functions/Function;Z)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static mergeDelayError(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "+", "Lio/reactivex/MaybeSource<", "+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 1102 invoke-static {p0}, Lio/reactivex/Flowable;->fromPublisher(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lio/reactivex/functions/Function; move-result-object v0 const/4 v1, 0x1 invoke-virtual {p0, v0, v1}, Lio/reactivex/Flowable;->flatMap(Lio/reactivex/functions/Function;Z)Lio/reactivex/Flowable; move-result-object p0 return-object p0 .end method .method public static never()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 1254 sget-object v0, Lio/reactivex/internal/operators/maybe/MaybeNever;->INSTANCE:Lio/reactivex/internal/operators/maybe/MaybeNever; 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 static sequenceEqual(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+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 .line 1280 invoke-static {}, Lio/reactivex/internal/functions/ObjectHelper;->equalsPredicate()Lio/reactivex/functions/BiPredicate; move-result-object v0 invoke-static {p0, p1, v0}, Lio/reactivex/Maybe;->sequenceEqual(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Single; move-result-object p0 return-object p0 .end method .method public static sequenceEqual(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/MaybeSource<", "+TT;>;", "Lio/reactivex/functions/BiPredicate<", "-TT;-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 .line 1310 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeEqualSingle; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/maybe/MaybeEqualSingle;->(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/BiPredicate;)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 timer(JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lio/reactivex/Maybe<", "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 1332 invoke-static {}, Lio/reactivex/schedulers/Schedulers;->computation()Lio/reactivex/Scheduler; move-result-object v0 invoke-static {p0, p1, p2, v0}, Lio/reactivex/Maybe;->timer(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static timer(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe; .locals 3 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Maybe<", "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 1356 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 1357 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1359 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeTimer; const-wide/16 v1, 0x0 invoke-static {v1, v2, p0, p1}, Ljava/lang/Math;->max(JJ)J move-result-wide p0 invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/maybe/MaybeTimer;->(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static unsafeCreate(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "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 .line 1376 instance-of v0, p0, Lio/reactivex/Maybe; if-nez v0, :cond_0 const-string v0, "onSubscribe is null" .line 1379 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1380 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeUnsafeCreate; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeUnsafeCreate;->(Lio/reactivex/MaybeSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .line 1377 :cond_0 new-instance p0, Ljava/lang/IllegalArgumentException; const-string v0, "unsafeCreate(Maybe) 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/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+TD;>;", "Lio/reactivex/functions/Function<", "-TD;+", "Lio/reactivex/MaybeSource<", "+TT;>;>;", "Lio/reactivex/functions/Consumer<", "-TD;>;)", "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/4 v0, 0x1 .line 1409 invoke-static {p0, p1, p2, v0}, Lio/reactivex/Maybe;->using(Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;Z)Lio/reactivex/Maybe; 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/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+TD;>;", "Lio/reactivex/functions/Function<", "-TD;+", "Lio/reactivex/MaybeSource<", "+TT;>;>;", "Lio/reactivex/functions/Consumer<", "-TD;>;Z)", "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, "resourceSupplier is null" .line 1444 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "sourceSupplier is null" .line 1445 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 1446 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1447 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeUsing; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/maybe/MaybeUsing;->(Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;Z)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static wrap(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "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 .line 1464 instance-of v0, p0, Lio/reactivex/Maybe; if-eqz v0, :cond_0 .line 1465 check-cast p0, Lio/reactivex/Maybe; invoke-static {p0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 :cond_0 const-string v0, "onSubscribe is null" .line 1467 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1468 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeUnsafeCreate; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeUnsafeCreate;->(Lio/reactivex/MaybeSource;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function9;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT1;>;", "Lio/reactivex/MaybeSource<", "+TT2;>;", "Lio/reactivex/MaybeSource<", "+TT3;>;", "Lio/reactivex/MaybeSource<", "+TT4;>;", "Lio/reactivex/MaybeSource<", "+TT5;>;", "Lio/reactivex/MaybeSource<", "+TT6;>;", "Lio/reactivex/MaybeSource<", "+TT7;>;", "Lio/reactivex/MaybeSource<", "+TT8;>;", "Lio/reactivex/MaybeSource<", "+TT9;>;", "Lio/reactivex/functions/Function9<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;-TT9;+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, "source1 is null" .line 1904 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 1905 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 1906 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 1907 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 1908 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 1909 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 1910 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 1911 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 1912 invoke-static {p8, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1913 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/MaybeSource; 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/Maybe;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function8;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT1;>;", "Lio/reactivex/MaybeSource<", "+TT2;>;", "Lio/reactivex/MaybeSource<", "+TT3;>;", "Lio/reactivex/MaybeSource<", "+TT4;>;", "Lio/reactivex/MaybeSource<", "+TT5;>;", "Lio/reactivex/MaybeSource<", "+TT6;>;", "Lio/reactivex/MaybeSource<", "+TT7;>;", "Lio/reactivex/MaybeSource<", "+TT8;>;", "Lio/reactivex/functions/Function8<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;+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, "source1 is null" .line 1838 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 1839 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 1840 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 1841 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 1842 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 1843 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 1844 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 1845 invoke-static {p7, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1846 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/MaybeSource; 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/Maybe;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function7;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT1;>;", "Lio/reactivex/MaybeSource<", "+TT2;>;", "Lio/reactivex/MaybeSource<", "+TT3;>;", "Lio/reactivex/MaybeSource<", "+TT4;>;", "Lio/reactivex/MaybeSource<", "+TT5;>;", "Lio/reactivex/MaybeSource<", "+TT6;>;", "Lio/reactivex/MaybeSource<", "+TT7;>;", "Lio/reactivex/functions/Function7<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;+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, "source1 is null" .line 1777 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 1778 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 1779 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 1780 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 1781 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 1782 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 1783 invoke-static {p6, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1784 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/MaybeSource; 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/Maybe;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function6;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT1;>;", "Lio/reactivex/MaybeSource<", "+TT2;>;", "Lio/reactivex/MaybeSource<", "+TT3;>;", "Lio/reactivex/MaybeSource<", "+TT4;>;", "Lio/reactivex/MaybeSource<", "+TT5;>;", "Lio/reactivex/MaybeSource<", "+TT6;>;", "Lio/reactivex/functions/Function6<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;+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, "source1 is null" .line 1720 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 1721 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 1722 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 1723 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 1724 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 1725 invoke-static {p5, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1726 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/MaybeSource; 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/Maybe;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function5;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT1;>;", "Lio/reactivex/MaybeSource<", "+TT2;>;", "Lio/reactivex/MaybeSource<", "+TT3;>;", "Lio/reactivex/MaybeSource<", "+TT4;>;", "Lio/reactivex/MaybeSource<", "+TT5;>;", "Lio/reactivex/functions/Function5<", "-TT1;-TT2;-TT3;-TT4;-TT5;+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, "source1 is null" .line 1668 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 1669 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 1670 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 1671 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 1672 invoke-static {p4, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1673 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/MaybeSource; 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/Maybe;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function4;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT1;>;", "Lio/reactivex/MaybeSource<", "+TT2;>;", "Lio/reactivex/MaybeSource<", "+TT3;>;", "Lio/reactivex/MaybeSource<", "+TT4;>;", "Lio/reactivex/functions/Function4<", "-TT1;-TT2;-TT3;-TT4;+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, "source1 is null" .line 1620 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 1621 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 1622 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 1623 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1624 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/MaybeSource; 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/Maybe;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function3;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT1;>;", "Lio/reactivex/MaybeSource<", "+TT2;>;", "Lio/reactivex/MaybeSource<", "+TT3;>;", "Lio/reactivex/functions/Function3<", "-TT1;-TT2;-TT3;+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, "source1 is null" .line 1576 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 1577 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 1578 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1579 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/MaybeSource; 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/Maybe;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static zip(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/BiFunction;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TT1;>;", "Lio/reactivex/MaybeSource<", "+TT2;>;", "Lio/reactivex/functions/BiFunction<", "-TT1;-TT2;+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, "source1 is null" .line 1537 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 1538 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1539 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/MaybeSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 invoke-static {p2, v0}, Lio/reactivex/Maybe;->zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static zip(Ljava/lang/Iterable;Lio/reactivex/functions/Function;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lio/reactivex/MaybeSource<", "+TT;>;>;", "Lio/reactivex/functions/Function<", "-[", "Ljava/lang/Object;", "+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, "zipper is null" .line 1501 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "sources is null" .line 1502 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1503 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeZipIterable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeZipIterable;->(Ljava/lang/Iterable;Lio/reactivex/functions/Function;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method .method public static varargs zipArray(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-[", "Ljava/lang/Object;", "+TR;>;[", "Lio/reactivex/MaybeSource<", "+TT;>;)", "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, "sources is null" .line 1947 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1948 array-length v0, p1 if-nez v0, :cond_0 .line 1949 invoke-static {}, Lio/reactivex/Maybe;->empty()Lio/reactivex/Maybe; move-result-object p0 return-object p0 :cond_0 const-string v0, "zipper is null" .line 1951 invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 1952 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeZipArray; invoke-direct {v0, p1, p0}, Lio/reactivex/internal/operators/maybe/MaybeZipArray;->([Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p0 return-object p0 .end method # virtual methods .method public final ambWith(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+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, "other is null" .line 1978 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 .line 1979 new-array v0, v0, [Lio/reactivex/MaybeSource; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 v1, 0x1 aput-object p1, v0, v1 invoke-static {v0}, Lio/reactivex/Maybe;->ambArray([Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; 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 1994 new-instance v0, Lio/reactivex/internal/observers/BlockingMultiObserver; invoke-direct {v0}, Lio/reactivex/internal/observers/BlockingMultiObserver;->()V .line 1995 invoke-virtual {p0, v0}, Lio/reactivex/Maybe;->subscribe(Lio/reactivex/MaybeObserver;)V .line 1996 invoke-virtual {v0}, Lio/reactivex/internal/observers/BlockingMultiObserver;->blockingGet()Ljava/lang/Object; move-result-object v0 return-object v0 .end method .method public final blockingGet(Ljava/lang/Object;)Ljava/lang/Object; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(TT;)TT;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "defaultValue is null" .line 2012 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2013 new-instance v0, Lio/reactivex/internal/observers/BlockingMultiObserver; invoke-direct {v0}, Lio/reactivex/internal/observers/BlockingMultiObserver;->()V .line 2014 invoke-virtual {p0, v0}, Lio/reactivex/Maybe;->subscribe(Lio/reactivex/MaybeObserver;)V .line 2015 invoke-virtual {v0, p1}, Lio/reactivex/internal/observers/BlockingMultiObserver;->blockingGet(Ljava/lang/Object;)Ljava/lang/Object; move-result-object p1 return-object p1 .end method .method public final cache()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 2040 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeCache; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeCache;->(Lio/reactivex/MaybeSource;)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 cast(Ljava/lang/Class;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Class<", "+TU;>;)", "Lio/reactivex/Maybe<", "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 2057 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2058 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/Maybe;->map(Lio/reactivex/functions/Function;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final compose(Lio/reactivex/MaybeTransformer;)Lio/reactivex/Maybe; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeTransformer<", "-TT;+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 .line 2083 invoke-interface {p1, p0}, Lio/reactivex/MaybeTransformer;->apply(Lio/reactivex/Maybe;)Lio/reactivex/MaybeSource; move-result-object p1 invoke-static {p1}, Lio/reactivex/Maybe;->wrap(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final concatMap(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 2105 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2106 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFlatten; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFlatten;->(Lio/reactivex/MaybeSource;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 concatWith(Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+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, "other is null" .line 2132 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2133 invoke-static {p0, p1}, Lio/reactivex/Maybe;->concat(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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 const-string v0, "item is null" .line 2155 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2156 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeContains; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeContains;->(Lio/reactivex/MaybeSource;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 count()Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/Single<", "Ljava/lang/Long;", ">;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2177 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeCount; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeCount;->(Lio/reactivex/MaybeSource;)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 defaultIfEmpty(Ljava/lang/Object;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(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, "item is null" .line 2199 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2200 invoke-static {p1}, Lio/reactivex/Maybe;->just(Ljava/lang/Object;)Lio/reactivex/Maybe; move-result-object p1 invoke-virtual {p0, p1}, Lio/reactivex/Maybe;->switchIfEmpty(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final delay(JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lio/reactivex/Maybe<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 2224 invoke-static {}, Lio/reactivex/schedulers/Schedulers;->computation()Lio/reactivex/Scheduler; move-result-object v0 invoke-virtual {p0, p1, p2, p3, v0}, Lio/reactivex/Maybe;->delay(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final delay(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Maybe<", "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 2249 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 2250 invoke-static {p4, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2251 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeDelay; const-wide/16 v1, 0x0 invoke-static {v1, v2, p1, p2}, Ljava/lang/Math;->max(JJ)J move-result-wide v3 move-object v1, v0 move-object v2, p0 move-object v5, p3 move-object v6, p4 invoke-direct/range {v1 .. v6}, Lio/reactivex/internal/operators/maybe/MaybeDelay;->(Lio/reactivex/MaybeSource;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)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 delay(Lorg/reactivestreams/Publisher;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "TU;>;)", "Lio/reactivex/Maybe<", "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 .line 2281 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeDelayOtherPublisher; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeDelayOtherPublisher;->(Lio/reactivex/MaybeSource;Lorg/reactivestreams/Publisher;)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 delaySubscription(JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lio/reactivex/Maybe<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 2328 invoke-static {}, Lio/reactivex/schedulers/Schedulers;->computation()Lio/reactivex/Scheduler; move-result-object v0 invoke-virtual {p0, p1, p2, p3, v0}, Lio/reactivex/Maybe;->delaySubscription(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final delaySubscription(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Maybe<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation .line 2354 invoke-static {p1, p2, p3, p4}, Lio/reactivex/Flowable;->timer(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Flowable; move-result-object p1 invoke-virtual {p0, p1}, Lio/reactivex/Maybe;->delaySubscription(Lorg/reactivestreams/Publisher;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final delaySubscription(Lorg/reactivestreams/Publisher;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "TU;>;)", "Lio/reactivex/Maybe<", "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, "subscriptionIndicator is null" .line 2305 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2306 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeDelaySubscriptionOtherPublisher; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeDelaySubscriptionOtherPublisher;->(Lio/reactivex/MaybeSource;Lorg/reactivestreams/Publisher;)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 doAfterSuccess(Lio/reactivex/functions/Consumer;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Consumer<", "-TT;>;)", "Lio/reactivex/Maybe<", "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 2373 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2374 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeDoAfterSuccess; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeDoAfterSuccess;->(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Consumer;)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 doAfterTerminate(Lio/reactivex/functions/Action;)Lio/reactivex/Maybe; .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Action;", ")", "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 2397 new-instance v8, Lio/reactivex/internal/operators/maybe/MaybePeek; invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v2 invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v3 invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v4 sget-object v5, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; const-string v0, "onAfterTerminate is null" invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 move-object v6, p1 check-cast v6, Lio/reactivex/functions/Action; sget-object v7, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; move-object v0, v8 move-object v1, p0 invoke-direct/range {v0 .. v7}, Lio/reactivex/internal/operators/maybe/MaybePeek;->(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)V invoke-static {v8}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final doFinally(Lio/reactivex/functions/Action;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Action;", ")", "Lio/reactivex/Maybe<", "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 2426 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2427 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeDoFinally; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeDoFinally;->(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Action;)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 doOnComplete(Lio/reactivex/functions/Action;)Lio/reactivex/Maybe; .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Action;", ")", "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 2470 new-instance v8, Lio/reactivex/internal/operators/maybe/MaybePeek; invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v2 invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v3 invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v4 const-string v0, "onComplete is null" invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 move-object v5, p1 check-cast v5, Lio/reactivex/functions/Action; sget-object v6, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; sget-object v7, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; move-object v0, v8 move-object v1, p0 invoke-direct/range {v0 .. v7}, Lio/reactivex/internal/operators/maybe/MaybePeek;->(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)V invoke-static {v8}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final doOnDispose(Lio/reactivex/functions/Action;)Lio/reactivex/Maybe; .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Action;", ")", "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 2443 new-instance v8, Lio/reactivex/internal/operators/maybe/MaybePeek; invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v2 invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v3 invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v4 sget-object v5, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; sget-object v6, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; const-string v0, "onDispose is null" invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 move-object v7, p1 check-cast v7, Lio/reactivex/functions/Action; move-object v0, v8 move-object v1, p0 invoke-direct/range {v0 .. v7}, Lio/reactivex/internal/operators/maybe/MaybePeek;->(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)V invoke-static {v8}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final doOnError(Lio/reactivex/functions/Consumer;)Lio/reactivex/Maybe; .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Consumer<", "-", "Ljava/lang/Throwable;", ">;)", "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 2493 new-instance v8, Lio/reactivex/internal/operators/maybe/MaybePeek; invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v2 invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v3 const-string v0, "onError is null" invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 move-object v4, p1 check-cast v4, Lio/reactivex/functions/Consumer; sget-object v5, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; sget-object v6, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; sget-object v7, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; move-object v0, v8 move-object v1, p0 invoke-direct/range {v0 .. v7}, Lio/reactivex/internal/operators/maybe/MaybePeek;->(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)V invoke-static {v8}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final doOnEvent(Lio/reactivex/functions/BiConsumer;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/BiConsumer<", "-TT;-", "Ljava/lang/Throwable;", ">;)", "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, "onEvent is null" .line 2520 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2521 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeDoOnEvent; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeDoOnEvent;->(Lio/reactivex/MaybeSource;Lio/reactivex/functions/BiConsumer;)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 doOnSubscribe(Lio/reactivex/functions/Consumer;)Lio/reactivex/Maybe; .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Consumer<", "-", "Lio/reactivex/disposables/Disposable;", ">;)", "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 2537 new-instance v8, Lio/reactivex/internal/operators/maybe/MaybePeek; const-string v0, "onSubscribe is null" invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 move-object v2, p1 check-cast v2, Lio/reactivex/functions/Consumer; invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v3 invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v4 sget-object v5, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; sget-object v6, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; sget-object v7, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; move-object v0, v8 move-object v1, p0 invoke-direct/range {v0 .. v7}, Lio/reactivex/internal/operators/maybe/MaybePeek;->(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)V invoke-static {v8}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final doOnSuccess(Lio/reactivex/functions/Consumer;)Lio/reactivex/Maybe; .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Consumer<", "-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 .line 2560 new-instance v8, Lio/reactivex/internal/operators/maybe/MaybePeek; invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v2 const-string v0, "onSubscribe is null" invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 move-object v3, p1 check-cast v3, Lio/reactivex/functions/Consumer; invoke-static {}, Lio/reactivex/internal/functions/Functions;->emptyConsumer()Lio/reactivex/functions/Consumer; move-result-object v4 sget-object v5, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; sget-object v6, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; sget-object v7, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; move-object v0, v8 move-object v1, p0 invoke-direct/range {v0 .. v7}, Lio/reactivex/internal/operators/maybe/MaybePeek;->(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)V invoke-static {v8}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe; 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 2590 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2591 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFilter; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFilter;->(Lio/reactivex/MaybeSource;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/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 2614 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2615 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFlatten; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFlatten;->(Lio/reactivex/MaybeSource;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 flatMap(Lio/reactivex/functions/Function;Lio/reactivex/functions/BiFunction;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-TT;+", "Lio/reactivex/MaybeSource<", "+TU;>;>;", "Lio/reactivex/functions/BiFunction<", "-TT;-TU;+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 .line 2677 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFlatMapBiSelector; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/maybe/MaybeFlatMapBiSelector;->(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function;Lio/reactivex/functions/BiFunction;)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/functions/Function;Ljava/util/concurrent/Callable;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-TT;+", "Lio/reactivex/MaybeSource<", "+TR;>;>;", "Lio/reactivex/functions/Function<", "-", "Ljava/lang/Throwable;", "+", "Lio/reactivex/MaybeSource<", "+TR;>;>;", "Ljava/util/concurrent/Callable<", "+", "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, "onSuccessMapper is null" .line 2645 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onErrorMapper is null" .line 2646 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onCompleteSupplier is null" .line 2647 invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2648 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFlatMapNotification; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/maybe/MaybeFlatMapNotification;->(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;Ljava/util/concurrent/Callable;)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 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 2849 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2850 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFlatMapCompletable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFlatMapCompletable;->(Lio/reactivex/MaybeSource;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 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 2749 invoke-virtual {p0}, Lio/reactivex/Maybe;->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 2775 invoke-virtual {p0}, Lio/reactivex/Maybe;->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 flatMapSingle(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 2799 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2800 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFlatMapSingle; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFlatMapSingle;->(Lio/reactivex/MaybeSource;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 flatMapSingleElement(Lio/reactivex/functions/Function;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-TT;+", "Lio/reactivex/SingleSource<", "+TR;>;>;)", "Lio/reactivex/Maybe<", "TR;>;" } .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, "mapper is null" .line 2826 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2827 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFlatMapSingleElement; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFlatMapSingleElement;->(Lio/reactivex/MaybeSource;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 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 2704 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFlatMapIterableFlowable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFlatMapIterableFlowable;->(Lio/reactivex/MaybeSource;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 2727 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeFlatMapIterableObservable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFlatMapIterableObservable;->(Lio/reactivex/MaybeSource;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/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 2866 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeHide; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeHide;->(Lio/reactivex/MaybeSource;)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 ignoreElement()Lio/reactivex/Completable; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 2885 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeIgnoreElementCompletable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeIgnoreElementCompletable;->(Lio/reactivex/MaybeSource;)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 isEmpty()Lio/reactivex/Single; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "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 2903 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeIsEmptySingle; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeIsEmptySingle;->(Lio/reactivex/MaybeSource;)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/MaybeOperator;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeOperator<", "+TR;-TT;>;)", "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, "onLift is null" .line 2932 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2933 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeLift; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeLift;->(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeOperator;)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 map(Lio/reactivex/functions/Function;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-TT;+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 2955 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2956 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeMap; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeMap;->(Lio/reactivex/MaybeSource;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 mergeWith(Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+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, "other is null" .line 2982 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2983 invoke-static {p0, p1}, Lio/reactivex/Maybe;->merge(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable; move-result-object p1 return-object p1 .end method .method public final observeOn(Lio/reactivex/Scheduler;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Maybe<", "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 3007 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3008 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeObserveOn; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeObserveOn;->(Lio/reactivex/MaybeSource;Lio/reactivex/Scheduler;)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 ofType(Ljava/lang/Class;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Class<", "TU;>;)", "Lio/reactivex/Maybe<", "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 3030 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3031 invoke-static {p1}, Lio/reactivex/internal/functions/Functions;->isInstanceOf(Ljava/lang/Class;)Lio/reactivex/functions/Predicate; move-result-object v0 invoke-virtual {p0, v0}, Lio/reactivex/Maybe;->filter(Lio/reactivex/functions/Predicate;)Lio/reactivex/Maybe; move-result-object v0 invoke-virtual {v0, p1}, Lio/reactivex/Maybe;->cast(Ljava/lang/Class;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final onErrorComplete()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 3143 invoke-static {}, Lio/reactivex/internal/functions/Functions;->alwaysTrue()Lio/reactivex/functions/Predicate; move-result-object v0 invoke-virtual {p0, v0}, Lio/reactivex/Maybe;->onErrorComplete(Lio/reactivex/functions/Predicate;)Lio/reactivex/Maybe; move-result-object v0 return-object v0 .end method .method public final onErrorComplete(Lio/reactivex/functions/Predicate;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Predicate<", "-", "Ljava/lang/Throwable;", ">;)", "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 3160 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3162 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeOnErrorComplete; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeOnErrorComplete;->(Lio/reactivex/MaybeSource;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 onErrorResumeNext(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+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, "next is null" .line 3187 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3188 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/Maybe;->onErrorResumeNext(Lio/reactivex/functions/Function;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final onErrorResumeNext(Lio/reactivex/functions/Function;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-", "Ljava/lang/Throwable;", "+", "Lio/reactivex/MaybeSource<", "+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, "resumeFunction is null" .line 3213 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3214 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeOnErrorNext; const/4 v1, 0x1 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/internal/operators/maybe/MaybeOnErrorNext;->(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function;Z)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 onErrorReturn(Lio/reactivex/functions/Function;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-", "Ljava/lang/Throwable;", "+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, "valueSupplier is null" .line 3239 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3240 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeOnErrorReturn; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeOnErrorReturn;->(Lio/reactivex/MaybeSource;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 onErrorReturnItem(Ljava/lang/Object;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(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, "item is null" .line 3264 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3265 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/Maybe;->onErrorReturn(Lio/reactivex/functions/Function;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final onExceptionResumeNext(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+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, "next is null" .line 3293 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3294 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeOnErrorNext; invoke-static {p1}, Lio/reactivex/internal/functions/Functions;->justFunction(Ljava/lang/Object;)Lio/reactivex/functions/Function; move-result-object p1 const/4 v1, 0x0 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/internal/operators/maybe/MaybeOnErrorNext;->(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function;Z)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 onTerminateDetach()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 3309 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeDetach; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeDetach;->(Lio/reactivex/MaybeSource;)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 repeat()Lio/reactivex/Flowable; .locals 2 .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 const-wide v0, 0x7fffffffffffffffL .line 3330 invoke-virtual {p0, v0, v1}, Lio/reactivex/Maybe;->repeat(J)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 3358 invoke-virtual {p0}, Lio/reactivex/Maybe;->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 3385 invoke-virtual {p0}, Lio/reactivex/Maybe;->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<", "*>;>;)", "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 3414 invoke-virtual {p0}, Lio/reactivex/Maybe;->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/Maybe; .locals 3 .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 3437 invoke-static {}, Lio/reactivex/internal/functions/Functions;->alwaysTrue()Lio/reactivex/functions/Predicate; move-result-object v0 const-wide v1, 0x7fffffffffffffffL invoke-virtual {p0, v1, v2, v0}, Lio/reactivex/Maybe;->retry(JLio/reactivex/functions/Predicate;)Lio/reactivex/Maybe; move-result-object v0 return-object v0 .end method .method public final retry(J)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J)", "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 3485 invoke-static {}, Lio/reactivex/internal/functions/Functions;->alwaysTrue()Lio/reactivex/functions/Predicate; move-result-object v0 invoke-virtual {p0, p1, p2, v0}, Lio/reactivex/Maybe;->retry(JLio/reactivex/functions/Predicate;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final retry(JLio/reactivex/functions/Predicate;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Lio/reactivex/functions/Predicate<", "-", "Ljava/lang/Throwable;", ">;)", "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 3502 invoke-virtual {p0}, Lio/reactivex/Maybe;->toFlowable()Lio/reactivex/Flowable; move-result-object v0 invoke-virtual {v0, p1, p2, p3}, Lio/reactivex/Flowable;->retry(JLio/reactivex/functions/Predicate;)Lio/reactivex/Flowable; move-result-object p1 invoke-virtual {p1}, Lio/reactivex/Flowable;->singleElement()Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final retry(Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/BiPredicate<", "-", "Ljava/lang/Integer;", "-", "Ljava/lang/Throwable;", ">;)", "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 3460 invoke-virtual {p0}, Lio/reactivex/Maybe;->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-virtual {p1}, Lio/reactivex/Flowable;->singleElement()Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final retry(Lio/reactivex/functions/Predicate;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Predicate<", "-", "Ljava/lang/Throwable;", ">;)", "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-wide v0, 0x7fffffffffffffffL .line 3518 invoke-virtual {p0, v0, v1, p1}, Lio/reactivex/Maybe;->retry(JLio/reactivex/functions/Predicate;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final retryUntil(Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/BooleanSupplier;", ")", "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, "stop is null" .line 3533 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3534 invoke-static {p1}, Lio/reactivex/internal/functions/Functions;->predicateReverseFor(Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/functions/Predicate; move-result-object p1 const-wide v0, 0x7fffffffffffffffL invoke-virtual {p0, v0, v1, p1}, Lio/reactivex/Maybe;->retry(JLio/reactivex/functions/Predicate;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final retryWhen(Lio/reactivex/functions/Function;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-", "Lio/reactivex/Flowable<", "Ljava/lang/Throwable;", ">;+", "Lorg/reactivestreams/Publisher<", "*>;>;)", "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 3589 invoke-virtual {p0}, Lio/reactivex/Maybe;->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-virtual {p1}, Lio/reactivex/Flowable;->singleElement()Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final subscribe()Lio/reactivex/disposables/Disposable; .locals 3 .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 3607 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; sget-object v2, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; invoke-virtual {p0, v0, v1, v2}, Lio/reactivex/Maybe;->subscribe(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;)Lio/reactivex/disposables/Disposable; move-result-object v0 return-object v0 .end method .method public final subscribe(Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable; .locals 2 .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 3630 sget-object v0, Lio/reactivex/internal/functions/Functions;->ERROR_CONSUMER:Lio/reactivex/functions/Consumer; sget-object v1, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; invoke-virtual {p0, p1, v0, v1}, Lio/reactivex/Maybe;->subscribe(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;)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 .line 3656 sget-object v0, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action; invoke-virtual {p0, p1, p2, v0}, Lio/reactivex/Maybe;->subscribe(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;)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/functions/Action;)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/functions/Action;", ")", "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 3687 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeCallbackObserver; invoke-direct {v0, p1, p2, p3}, Lio/reactivex/internal/operators/maybe/MaybeCallbackObserver;->(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;)V invoke-virtual {p0, v0}, Lio/reactivex/Maybe;->subscribeWith(Lio/reactivex/MaybeObserver;)Lio/reactivex/MaybeObserver; move-result-object p1 check-cast p1, Lio/reactivex/disposables/Disposable; return-object p1 .end method .method public final subscribe(Lio/reactivex/MaybeObserver;)V .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeObserver<", "-TT;>;)V" } .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "observer is null" .line 3693 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3695 invoke-static {p0, p1}, Lio/reactivex/plugins/RxJavaPlugins;->onSubscribe(Lio/reactivex/Maybe;Lio/reactivex/MaybeObserver;)Lio/reactivex/MaybeObserver; move-result-object p1 const-string v0, "observer returned by the RxJavaPlugins hook is null" .line 3697 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3700 :try_start_0 invoke-virtual {p0, p1}, Lio/reactivex/Maybe;->subscribeActual(Lio/reactivex/MaybeObserver;)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 3704 invoke-static {p1}, Lio/reactivex/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V .line 3705 new-instance v0, Ljava/lang/NullPointerException; const-string v1, "subscribeActual failed" invoke-direct {v0, v1}, Ljava/lang/NullPointerException;->(Ljava/lang/String;)V .line 3706 invoke-virtual {v0, p1}, Ljava/lang/NullPointerException;->initCause(Ljava/lang/Throwable;)Ljava/lang/Throwable; .line 3707 throw v0 :catch_1 move-exception p1 .line 3702 throw p1 .end method .method protected abstract subscribeActual(Lio/reactivex/MaybeObserver;)V .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeObserver<", "-TT;>;)V" } .end annotation .end method .method public final subscribeOn(Lio/reactivex/Scheduler;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Maybe<", "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 3736 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3737 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeSubscribeOn; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeSubscribeOn;->(Lio/reactivex/MaybeSource;Lio/reactivex/Scheduler;)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 subscribeWith(Lio/reactivex/MaybeObserver;)Lio/reactivex/MaybeObserver; .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 3766 invoke-virtual {p0, p1}, Lio/reactivex/Maybe;->subscribe(Lio/reactivex/MaybeObserver;)V return-object p1 .end method .method public final switchIfEmpty(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+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, "other is null" .line 3789 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3790 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeSwitchIfEmpty; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeSwitchIfEmpty;->(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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 takeUntil(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "TU;>;)", "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, "other is null" .line 3814 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3815 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeTakeUntilMaybe; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeTakeUntilMaybe;->(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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 takeUntil(Lorg/reactivestreams/Publisher;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "TU;>;)", "Lio/reactivex/Maybe<", "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, "other is null" .line 3843 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3844 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeTakeUntilPublisher; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeTakeUntilPublisher;->(Lio/reactivex/MaybeSource;Lorg/reactivestreams/Publisher;)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 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 4111 new-instance v0, Lio/reactivex/observers/TestObserver; invoke-direct {v0}, Lio/reactivex/observers/TestObserver;->()V .line 4112 invoke-virtual {p0, v0}, Lio/reactivex/Maybe;->subscribe(Lio/reactivex/MaybeObserver;)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 4129 new-instance v0, Lio/reactivex/observers/TestObserver; invoke-direct {v0}, Lio/reactivex/observers/TestObserver;->()V if-eqz p1, :cond_0 .line 4132 invoke-virtual {v0}, Lio/reactivex/observers/TestObserver;->cancel()V .line 4135 :cond_0 invoke-virtual {p0, v0}, Lio/reactivex/Maybe;->subscribe(Lio/reactivex/MaybeObserver;)V return-object v0 .end method .method public final timeout(JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lio/reactivex/Maybe<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 3868 invoke-static {}, Lio/reactivex/schedulers/Schedulers;->computation()Lio/reactivex/Scheduler; move-result-object v0 invoke-virtual {p0, p1, p2, p3, v0}, Lio/reactivex/Maybe;->timeout(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final timeout(JLjava/util/concurrent/TimeUnit;Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/MaybeSource<", "+TT;>;)", "Lio/reactivex/Maybe<", "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 3894 invoke-static {p4, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3895 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-virtual/range {v1 .. v6}, Lio/reactivex/Maybe;->timeout(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final timeout(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Maybe<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation .line 3951 invoke-static {p1, p2, p3, p4}, Lio/reactivex/Maybe;->timer(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe; move-result-object p1 invoke-virtual {p0, p1}, Lio/reactivex/Maybe;->timeout(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final timeout(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lio/reactivex/Scheduler;", "Lio/reactivex/MaybeSource<", "+TT;>;)", "Lio/reactivex/Maybe<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "fallback is null" .line 3923 invoke-static {p5, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3924 invoke-static {p1, p2, p3, p4}, Lio/reactivex/Maybe;->timer(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe; move-result-object p1 invoke-virtual {p0, p1, p5}, Lio/reactivex/Maybe;->timeout(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method .method public final timeout(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "TU;>;)", "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, "timeoutIndicator is null" .line 3969 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3970 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeTimeoutMaybe; const/4 v1, 0x0 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/internal/operators/maybe/MaybeTimeoutMaybe;->(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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 timeout(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "TU;>;", "Lio/reactivex/MaybeSource<", "+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, "timeoutIndicator is null" .line 3990 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "fallback is null" .line 3991 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3992 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeTimeoutMaybe; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/maybe/MaybeTimeoutMaybe;->(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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 timeout(Lorg/reactivestreams/Publisher;)Lio/reactivex/Maybe; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "TU;>;)", "Lio/reactivex/Maybe<", "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, "timeoutIndicator is null" .line 4014 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 4015 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeTimeoutPublisher; const/4 v1, 0x0 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/internal/operators/maybe/MaybeTimeoutPublisher;->(Lio/reactivex/MaybeSource;Lorg/reactivestreams/Publisher;Lio/reactivex/MaybeSource;)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 timeout(Lorg/reactivestreams/Publisher;Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Publisher<", "TU;>;", "Lio/reactivex/MaybeSource<", "+TT;>;)", "Lio/reactivex/Maybe<", "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, "timeoutIndicator is null" .line 4039 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "fallback is null" .line 4040 invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 4041 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeTimeoutPublisher; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/maybe/MaybeTimeoutPublisher;->(Lio/reactivex/MaybeSource;Lorg/reactivestreams/Publisher;Lio/reactivex/MaybeSource;)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 to(Lio/reactivex/functions/Function;)Ljava/lang/Object; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Function<", "-", "Lio/reactivex/Maybe<", "TT;>;TR;>;)TR;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 3051 :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 3053 invoke-static {p1}, Lio/reactivex/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V .line 3054 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 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 3074 instance-of v0, p0, Lio/reactivex/internal/fuseable/FuseToFlowable; if-eqz v0, :cond_0 .line 3075 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 3077 :cond_0 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeToFlowable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeToFlowable;->(Lio/reactivex/MaybeSource;)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 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 3093 instance-of v0, p0, Lio/reactivex/internal/fuseable/FuseToObservable; if-eqz v0, :cond_0 .line 3094 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 3096 :cond_0 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeToObservable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeToObservable;->(Lio/reactivex/MaybeSource;)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 toSingle()Lio/reactivex/Single; .locals 2 .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 3128 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeToSingle; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/internal/operators/maybe/MaybeToSingle;->(Lio/reactivex/MaybeSource;Ljava/lang/Object;)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 toSingle(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, "defaultValue is null" .line 3112 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3113 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeToSingle; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeToSingle;->(Lio/reactivex/MaybeSource;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 unsubscribeOn(Lio/reactivex/Scheduler;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/Scheduler;", ")", "Lio/reactivex/Maybe<", "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 4058 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 4059 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeUnsubscribeOn; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeUnsubscribeOn;->(Lio/reactivex/MaybeSource;Lio/reactivex/Scheduler;)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 zipWith(Lio/reactivex/MaybeSource;Lio/reactivex/functions/BiFunction;)Lio/reactivex/Maybe; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/MaybeSource<", "+TU;>;", "Lio/reactivex/functions/BiFunction<", "-TT;-TU;+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, "other is null" .line 4091 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 4092 invoke-static {p0, p1, p2}, Lio/reactivex/Maybe;->zip(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/BiFunction;)Lio/reactivex/Maybe; move-result-object p1 return-object p1 .end method