n.smali
.class public final Lio/reactivex/internal/observers/n;
.super Ljava/lang/Object;
.source "SourceFile"
# interfaces
.implements Lio/reactivex/s;
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Lio/reactivex/s<",
"TT;>;"
}
.end annotation
# instance fields
.field public final a:Lio/reactivex/internal/disposables/g;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/internal/disposables/g<",
"TT;>;"
}
.end annotation
.end field
.field public b:Lio/reactivex/disposables/b;
# direct methods
.method public constructor <init>(Lio/reactivex/internal/disposables/g;)V
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/internal/disposables/g<",
"TT;>;)V"
}
.end annotation
.line 1
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 2
iput-object p1, p0, Lio/reactivex/internal/observers/n;->a:Lio/reactivex/internal/disposables/g;
return-void
.end method
# virtual methods
.method public final onComplete()V
.registers 3
iget-object v0, p0, Lio/reactivex/internal/observers/n;->a:Lio/reactivex/internal/disposables/g;
iget-object v1, p0, Lio/reactivex/internal/observers/n;->b:Lio/reactivex/disposables/b;
invoke-virtual {v0, v1}, Lio/reactivex/internal/disposables/g;->c(Lio/reactivex/disposables/b;)V
return-void
.end method
.method public final onError(Ljava/lang/Throwable;)V
.registers 4
iget-object v0, p0, Lio/reactivex/internal/observers/n;->a:Lio/reactivex/internal/disposables/g;
iget-object v1, p0, Lio/reactivex/internal/observers/n;->b:Lio/reactivex/disposables/b;
invoke-virtual {v0, p1, v1}, Lio/reactivex/internal/disposables/g;->d(Ljava/lang/Throwable;Lio/reactivex/disposables/b;)V
return-void
.end method
.method public final onNext(Ljava/lang/Object;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
iget-object v0, p0, Lio/reactivex/internal/observers/n;->a:Lio/reactivex/internal/disposables/g;
iget-object v1, p0, Lio/reactivex/internal/observers/n;->b:Lio/reactivex/disposables/b;
invoke-virtual {v0, p1, v1}, Lio/reactivex/internal/disposables/g;->e(Ljava/lang/Object;Lio/reactivex/disposables/b;)Z
return-void
.end method
.method public final onSubscribe(Lio/reactivex/disposables/b;)V
.registers 3
.line 1
iget-object v0, p0, Lio/reactivex/internal/observers/n;->b:Lio/reactivex/disposables/b;
invoke-static {v0, p1}, Lio/reactivex/internal/disposables/c;->validate(Lio/reactivex/disposables/b;Lio/reactivex/disposables/b;)Z
move-result v0
if-eqz v0, :cond_f
.line 2
iput-object p1, p0, Lio/reactivex/internal/observers/n;->b:Lio/reactivex/disposables/b;
.line 3
iget-object v0, p0, Lio/reactivex/internal/observers/n;->a:Lio/reactivex/internal/disposables/g;
invoke-virtual {v0, p1}, Lio/reactivex/internal/disposables/g;->f(Lio/reactivex/disposables/b;)Z
:cond_f
return-void
.end method