2022-06-10 21:38:30 +09:00

207 lines
4.7 KiB
Smali

.class public final Lio/reactivex/internal/operators/maybe/l$a;
.super Ljava/lang/Object;
.source "MaybeFilter.java"
# interfaces
.implements Lkh/t;
.implements Lio/reactivex/disposables/b;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/internal/operators/maybe/l;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x19
name = "a"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Lkh/t<",
"TT;>;",
"Lio/reactivex/disposables/b;"
}
.end annotation
# instance fields
.field public final a:Lkh/t;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lkh/t<",
"-TT;>;"
}
.end annotation
.end field
.field public final b:Lph/r;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lph/r<",
"-TT;>;"
}
.end annotation
.end field
.field public c:Lio/reactivex/disposables/b;
# direct methods
.method public constructor <init>(Lkh/t;Lph/r;)V
.locals 0
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lkh/t<",
"-TT;>;",
"Lph/r<",
"-TT;>;)V"
}
.end annotation
.line 1
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 2
iput-object p1, p0, Lio/reactivex/internal/operators/maybe/l$a;->a:Lkh/t;
.line 3
iput-object p2, p0, Lio/reactivex/internal/operators/maybe/l$a;->b:Lph/r;
return-void
.end method
# virtual methods
.method public dispose()V
.locals 2
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/l$a;->c:Lio/reactivex/disposables/b;
.line 2
sget-object v1, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
iput-object v1, p0, Lio/reactivex/internal/operators/maybe/l$a;->c:Lio/reactivex/disposables/b;
.line 3
invoke-interface {v0}, Lio/reactivex/disposables/b;->dispose()V
return-void
.end method
.method public isDisposed()Z
.locals 1
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/l$a;->c:Lio/reactivex/disposables/b;
invoke-interface {v0}, Lio/reactivex/disposables/b;->isDisposed()Z
move-result v0
return v0
.end method
.method public onComplete()V
.locals 1
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/l$a;->a:Lkh/t;
invoke-interface {v0}, Lkh/t;->onComplete()V
return-void
.end method
.method public onError(Ljava/lang/Throwable;)V
.locals 1
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/l$a;->a:Lkh/t;
invoke-interface {v0, p1}, Lkh/t;->onError(Ljava/lang/Throwable;)V
return-void
.end method
.method public onSubscribe(Lio/reactivex/disposables/b;)V
.locals 1
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/l$a;->c:Lio/reactivex/disposables/b;
invoke-static {v0, p1}, Lio/reactivex/internal/disposables/DisposableHelper;->validate(Lio/reactivex/disposables/b;Lio/reactivex/disposables/b;)Z
move-result v0
if-eqz v0, :cond_0
.line 2
iput-object p1, p0, Lio/reactivex/internal/operators/maybe/l$a;->c:Lio/reactivex/disposables/b;
.line 3
iget-object p1, p0, Lio/reactivex/internal/operators/maybe/l$a;->a:Lkh/t;
invoke-interface {p1, p0}, Lkh/t;->onSubscribe(Lio/reactivex/disposables/b;)V
:cond_0
return-void
.end method
.method public onSuccess(Ljava/lang/Object;)V
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.line 1
:try_start_0
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/l$a;->b:Lph/r;
invoke-interface {v0, p1}, Lph/r;->test(Ljava/lang/Object;)Z
move-result v0
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
if-eqz v0, :cond_0
.line 2
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/l$a;->a:Lkh/t;
invoke-interface {v0, p1}, Lkh/t;->onSuccess(Ljava/lang/Object;)V
goto :goto_0
.line 3
:cond_0
iget-object p1, p0, Lio/reactivex/internal/operators/maybe/l$a;->a:Lkh/t;
invoke-interface {p1}, Lkh/t;->onComplete()V
:goto_0
return-void
:catchall_0
move-exception p1
.line 4
invoke-static {p1}, Lio/reactivex/exceptions/a;->b(Ljava/lang/Throwable;)V
.line 5
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/l$a;->a:Lkh/t;
invoke-interface {v0, p1}, Lkh/t;->onError(Ljava/lang/Throwable;)V
return-void
.end method