f$a.smali
.class public final Lio/reactivex/internal/operators/maybe/f$a;
.super Ljava/util/concurrent/atomic/AtomicReference;
.source "SourceFile"
# interfaces
.implements Lio/reactivex/i;
.implements Lio/reactivex/disposables/b;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/internal/operators/maybe/f;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x19
name = "a"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/util/concurrent/atomic/AtomicReference<",
"Lio/reactivex/disposables/b;",
">;",
"Lio/reactivex/i<",
"TT;>;",
"Lio/reactivex/disposables/b;"
}
.end annotation
# static fields
.field private static final serialVersionUID:J = 0x76f356c87ebda749L
# instance fields
.field public final a:Lio/reactivex/internal/disposables/h;
.field public final b:Lio/reactivex/i;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/i<",
"-TT;>;"
}
.end annotation
.end field
# direct methods
.method public constructor <init>(Lio/reactivex/i;)V
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/i<",
"-TT;>;)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/f$a;->b:Lio/reactivex/i;
.line 3
new-instance p1, Lio/reactivex/internal/disposables/h;
invoke-direct {p1}, Lio/reactivex/internal/disposables/h;-><init>()V
iput-object p1, p0, Lio/reactivex/internal/operators/maybe/f$a;->a:Lio/reactivex/internal/disposables/h;
return-void
.end method
# virtual methods
.method public final dispose()V
.registers 2
.line 1
invoke-static {p0}, Lio/reactivex/internal/disposables/c;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z
.line 2
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/f$a;->a:Lio/reactivex/internal/disposables/h;
invoke-static {v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;)Ljava/lang/Object;
.line 3
invoke-static {v0}, Lio/reactivex/internal/disposables/c;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z
return-void
.end method
.method public final isDisposed()Z
.registers 2
invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lio/reactivex/disposables/b;
invoke-static {v0}, Lio/reactivex/internal/disposables/c;->isDisposed(Lio/reactivex/disposables/b;)Z
move-result v0
return v0
.end method
.method public final onComplete()V
.registers 2
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/f$a;->b:Lio/reactivex/i;
invoke-interface {v0}, Lio/reactivex/i;->onComplete()V
return-void
.end method
.method public final onError(Ljava/lang/Throwable;)V
.registers 3
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/f$a;->b:Lio/reactivex/i;
invoke-interface {v0, p1}, Lio/reactivex/i;->onError(Ljava/lang/Throwable;)V
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
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/f$a;->b:Lio/reactivex/i;
invoke-interface {v0, p1}, Lio/reactivex/i;->onSuccess(Ljava/lang/Object;)V
return-void
.end method