MaybeErrorCallable.smali
.class public final Lio/reactivex/internal/operators/maybe/MaybeErrorCallable;
.super Lio/reactivex/Maybe;
.source "MaybeErrorCallable.java"
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Lio/reactivex/Maybe<",
"TT;>;"
}
.end annotation
# instance fields
.field final errorSupplier:Ljava/util/concurrent/Callable;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/Callable<",
"+",
"Ljava/lang/Throwable;",
">;"
}
.end annotation
.end field
# direct methods
.method static constructor <clinit>()V
.registers 1
return-void
.end method
.method public constructor <init>(Ljava/util/concurrent/Callable;)V
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/concurrent/Callable<",
"+",
"Ljava/lang/Throwable;",
">;)V"
}
.end annotation
.line 32
.local p0, "this":Lio/reactivex/internal/operators/maybe/MaybeErrorCallable;, "Lio/reactivex/internal/operators/maybe/MaybeErrorCallable<TT;>;"
.local p1, "errorSupplier":Ljava/util/concurrent/Callable;, "Ljava/util/concurrent/Callable<+Ljava/lang/Throwable;>;"
invoke-direct {p0}, Lio/reactivex/Maybe;-><init>()V
.line 33
iput-object p1, p0, Lio/reactivex/internal/operators/maybe/MaybeErrorCallable;->errorSupplier:Ljava/util/concurrent/Callable;
.line 34
return-void
.end method
# virtual methods
.method protected subscribeActual(Lio/reactivex/MaybeObserver;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/MaybeObserver<",
"-TT;>;)V"
}
.end annotation
.line 38
.local p0, "this":Lio/reactivex/internal/operators/maybe/MaybeErrorCallable;, "Lio/reactivex/internal/operators/maybe/MaybeErrorCallable<TT;>;"
.local p1, "observer":Lio/reactivex/MaybeObserver;, "Lio/reactivex/MaybeObserver<-TT;>;"
invoke-static {}, Lio/reactivex/disposables/Disposables;->disposed()Lio/reactivex/disposables/Disposable;
move-result-object v0
invoke-interface {p1, v0}, Lio/reactivex/MaybeObserver;->onSubscribe(Lio/reactivex/disposables/Disposable;)V
.line 42
:try_start_7
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/MaybeErrorCallable;->errorSupplier:Ljava/util/concurrent/Callable;
invoke-interface {v0}, Ljava/util/concurrent/Callable;->call()Ljava/lang/Object;
move-result-object v0
const-string v1, "Callable returned null throwable. Null values are generally not allowed in 2.x operators and sources."
invoke-static {v0, v1}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Ljava/lang/Throwable;
:try_end_15
.catchall {:try_start_7 .. :try_end_15} :catchall_16
.line 46
.local v0, "ex":Ljava/lang/Throwable;
goto :goto_1b
.line 43
.end local v0 # "ex":Ljava/lang/Throwable;
:catchall_16
move-exception v0
.line 44
.local v0, "ex1":Ljava/lang/Throwable;
invoke-static {v0}, Lio/reactivex/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V
.line 45
move-object v1, v0
.line 48
.local v0, "ex":Ljava/lang/Throwable;
:goto_1b
invoke-interface {p1, v0}, Lio/reactivex/MaybeObserver;->onError(Ljava/lang/Throwable;)V
.line 49
return-void
.end method