g$a$a.smali
.class public final Lio/reactivex/internal/operators/maybe/g$a$a;
.super Ljava/util/concurrent/atomic/AtomicReference;
.source "SourceFile"
# interfaces
.implements Lio/reactivex/i;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/internal/operators/maybe/g$a;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x19
name = "a"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<U:",
"Ljava/lang/Object;",
">",
"Ljava/util/concurrent/atomic/AtomicReference<",
"Lio/reactivex/disposables/b;",
">;",
"Lio/reactivex/i<",
"TU;>;"
}
.end annotation
# static fields
.field private static final serialVersionUID:J = -0x1191e1deb0e3c2ebL
# instance fields
.field public final a:Lio/reactivex/internal/operators/maybe/g$a;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/internal/operators/maybe/g$a<",
"*TU;>;"
}
.end annotation
.end field
# direct methods
.method public constructor <init>(Lio/reactivex/internal/operators/maybe/g$a;)V
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/internal/operators/maybe/g$a<",
"*TU;>;)V"
}
.end annotation
.line 1
invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
.line 2
iput-object p1, p0, Lio/reactivex/internal/operators/maybe/g$a$a;->a:Lio/reactivex/internal/operators/maybe/g$a;
return-void
.end method
# virtual methods
.method public final onComplete()V
.registers 3
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/g$a$a;->a:Lio/reactivex/internal/operators/maybe/g$a;
invoke-static {v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;)Ljava/lang/Object;
.line 2
invoke-static {v0}, Lio/reactivex/internal/disposables/c;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z
move-result v1
if-eqz v1, :cond_10
.line 3
iget-object v0, v0, Lio/reactivex/internal/operators/maybe/g$a;->a:Lio/reactivex/i;
invoke-interface {v0}, Lio/reactivex/i;->onComplete()V
:cond_10
return-void
.end method
.method public final onError(Ljava/lang/Throwable;)V
.registers 4
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/g$a$a;->a:Lio/reactivex/internal/operators/maybe/g$a;
invoke-static {v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;)Ljava/lang/Object;
.line 2
invoke-static {v0}, Lio/reactivex/internal/disposables/c;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z
move-result v1
if-eqz v1, :cond_11
.line 3
iget-object v0, v0, Lio/reactivex/internal/operators/maybe/g$a;->a:Lio/reactivex/i;
invoke-interface {v0, p1}, Lio/reactivex/i;->onError(Ljava/lang/Throwable;)V
goto :goto_14
.line 4
:cond_11
invoke-static {p1}, Lio/reactivex/plugins/a;->b(Ljava/lang/Throwable;)V
:goto_14
return-void
.end method
.method public final onSubscribe(Lio/reactivex/disposables/b;)V
.registers 2
invoke-static {p0, p1}, Lio/reactivex/internal/disposables/c;->setOnce(Ljava/util/concurrent/atomic/AtomicReference;Lio/reactivex/disposables/b;)Z
return-void
.end method
.method public final onSuccess(Ljava/lang/Object;)V
.registers 3
.line 1
iget-object p1, p0, Lio/reactivex/internal/operators/maybe/g$a$a;->a:Lio/reactivex/internal/operators/maybe/g$a;
invoke-static {p1}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;)Ljava/lang/Object;
.line 2
invoke-static {p1}, Lio/reactivex/internal/disposables/c;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z
move-result v0
if-eqz v0, :cond_10
.line 3
iget-object p1, p1, Lio/reactivex/internal/operators/maybe/g$a;->a:Lio/reactivex/i;
invoke-interface {p1}, Lio/reactivex/i;->onComplete()V
:cond_10
return-void
.end method