c1$a.smali
.class public final Lio/reactivex/internal/operators/observable/c1$a;
.super Ljava/lang/Object;
.source "SourceFile"
# interfaces
.implements Lio/reactivex/g;
.implements Lio/reactivex/disposables/b;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/internal/operators/observable/c1;
.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;",
"Lio/reactivex/g<",
"TT;>;",
"Lio/reactivex/disposables/b;"
}
.end annotation
# instance fields
.field public final a:Lio/reactivex/s;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/s<",
"-TT;>;"
}
.end annotation
.end field
.field public b:Lorg/reactivestreams/c;
# direct methods
.method public constructor <init>(Lio/reactivex/s;)V
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/s<",
"-TT;>;)V"
}
.end annotation
.line 1
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 2
iput-object p1, p0, Lio/reactivex/internal/operators/observable/c1$a;->a:Lio/reactivex/s;
return-void
.end method
# virtual methods
.method public final dispose()V
.registers 2
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/observable/c1$a;->b:Lorg/reactivestreams/c;
invoke-interface {v0}, Lorg/reactivestreams/c;->cancel()V
.line 2
sget-object v0, Lio/reactivex/internal/subscriptions/f;->CANCELLED:Lio/reactivex/internal/subscriptions/f;
iput-object v0, p0, Lio/reactivex/internal/operators/observable/c1$a;->b:Lorg/reactivestreams/c;
return-void
.end method
.method public final isDisposed()Z
.registers 3
iget-object v0, p0, Lio/reactivex/internal/operators/observable/c1$a;->b:Lorg/reactivestreams/c;
sget-object v1, Lio/reactivex/internal/subscriptions/f;->CANCELLED:Lio/reactivex/internal/subscriptions/f;
if-ne v0, v1, :cond_8
const/4 v0, 0x1
goto :goto_9
:cond_8
const/4 v0, 0x0
:goto_9
return v0
.end method
.method public final onComplete()V
.registers 2
iget-object v0, p0, Lio/reactivex/internal/operators/observable/c1$a;->a:Lio/reactivex/s;
invoke-interface {v0}, Lio/reactivex/s;->onComplete()V
return-void
.end method
.method public final onError(Ljava/lang/Throwable;)V
.registers 3
iget-object v0, p0, Lio/reactivex/internal/operators/observable/c1$a;->a:Lio/reactivex/s;
invoke-interface {v0, p1}, Lio/reactivex/s;->onError(Ljava/lang/Throwable;)V
return-void
.end method
.method public final onNext(Ljava/lang/Object;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
iget-object v0, p0, Lio/reactivex/internal/operators/observable/c1$a;->a:Lio/reactivex/s;
invoke-interface {v0, p1}, Lio/reactivex/s;->onNext(Ljava/lang/Object;)V
return-void
.end method
.method public final onSubscribe(Lorg/reactivestreams/c;)V
.registers 4
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/observable/c1$a;->b:Lorg/reactivestreams/c;
invoke-static {v0, p1}, Lio/reactivex/internal/subscriptions/f;->validate(Lorg/reactivestreams/c;Lorg/reactivestreams/c;)Z
move-result v0
if-eqz v0, :cond_17
.line 2
iput-object p1, p0, Lio/reactivex/internal/operators/observable/c1$a;->b:Lorg/reactivestreams/c;
.line 3
iget-object v0, p0, Lio/reactivex/internal/operators/observable/c1$a;->a:Lio/reactivex/s;
invoke-interface {v0, p0}, Lio/reactivex/s;->onSubscribe(Lio/reactivex/disposables/b;)V
const-wide v0, 0x7fffffffffffffffL
.line 4
invoke-interface {p1, v0, v1}, Lorg/reactivestreams/c;->request(J)V
:cond_17
return-void
.end method