PublishProcessor$PublishSubscription.smali
.class final Lio/reactivex/processors/PublishProcessor$PublishSubscription;
.super Ljava/util/concurrent/atomic/AtomicLong;
.source "PublishProcessor.java"
# interfaces
.implements Lf/b/d;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/processors/PublishProcessor;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "PublishSubscription"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/util/concurrent/atomic/AtomicLong;",
"Lf/b/d;"
}
.end annotation
# static fields
.field private static final serialVersionUID:J = 0x3171d4005ebf93feL
# instance fields
.field final downstream:Lf/b/c;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lf/b/c<",
"-TT;>;"
}
.end annotation
.end field
.field final parent:Lio/reactivex/processors/PublishProcessor;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/processors/PublishProcessor<",
"TT;>;"
}
.end annotation
.end field
# direct methods
.method constructor <init>(Lf/b/c;Lio/reactivex/processors/PublishProcessor;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lf/b/c<",
"-TT;>;",
"Lio/reactivex/processors/PublishProcessor<",
"TT;>;)V"
}
.end annotation
.line 1
invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicLong;-><init>()V
.line 2
iput-object p1, p0, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->downstream:Lf/b/c;
.line 3
iput-object p2, p0, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->parent:Lio/reactivex/processors/PublishProcessor;
return-void
.end method
# virtual methods
.method public cancel()V
.registers 6
const-wide/high16 v0, -0x8000000000000000L
.line 1
invoke-virtual {p0, v0, v1}, Ljava/util/concurrent/atomic/AtomicLong;->getAndSet(J)J
move-result-wide v2
cmp-long v4, v2, v0
if-eqz v4, :cond_f
.line 2
iget-object v0, p0, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->parent:Lio/reactivex/processors/PublishProcessor;
invoke-virtual {v0, p0}, Lio/reactivex/processors/PublishProcessor;->b(Lio/reactivex/processors/PublishProcessor$PublishSubscription;)V
:cond_f
return-void
.end method
.method public isCancelled()Z
.registers 6
.line 1
invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v0
const-wide/high16 v2, -0x8000000000000000L
cmp-long v4, v0, v2
if-nez v4, :cond_c
const/4 v0, 0x1
goto :goto_d
:cond_c
const/4 v0, 0x0
:goto_d
return v0
.end method
.method isFull()Z
.registers 6
.line 1
invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v0
const-wide/16 v2, 0x0
cmp-long v4, v0, v2
if-nez v4, :cond_c
const/4 v0, 0x1
goto :goto_d
:cond_c
const/4 v0, 0x0
:goto_d
return v0
.end method
.method public onComplete()V
.registers 6
.line 1
invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v0
const-wide/high16 v2, -0x8000000000000000L
cmp-long v4, v0, v2
if-eqz v4, :cond_f
.line 2
iget-object v0, p0, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->downstream:Lf/b/c;
invoke-interface {v0}, Lf/b/c;->onComplete()V
:cond_f
return-void
.end method
.method public onError(Ljava/lang/Throwable;)V
.registers 7
.line 1
invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v0
const-wide/high16 v2, -0x8000000000000000L
cmp-long v4, v0, v2
if-eqz v4, :cond_10
.line 2
iget-object v0, p0, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->downstream:Lf/b/c;
invoke-interface {v0, p1}, Lf/b/c;->onError(Ljava/lang/Throwable;)V
goto :goto_13
.line 3
:cond_10
invoke-static {p1}, Lio/reactivex/e/a;->b(Ljava/lang/Throwable;)V
:goto_13
return-void
.end method
.method public onNext(Ljava/lang/Object;)V
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.line 1
invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v0
const-wide/high16 v2, -0x8000000000000000L
cmp-long v4, v0, v2
if-nez v4, :cond_b
return-void
:cond_b
const-wide/16 v2, 0x0
cmp-long v4, v0, v2
if-eqz v4, :cond_1c
.line 2
iget-object v0, p0, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->downstream:Lf/b/c;
invoke-interface {v0, p1}, Lf/b/c;->onNext(Ljava/lang/Object;)V
const-wide/16 v0, 0x1
.line 3
invoke-static {p0, v0, v1}, Lio/reactivex/internal/util/b;->d(Ljava/util/concurrent/atomic/AtomicLong;J)J
goto :goto_2b
.line 4
:cond_1c
invoke-virtual {p0}, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->cancel()V
.line 5
iget-object p1, p0, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->downstream:Lf/b/c;
new-instance v0, Lio/reactivex/exceptions/MissingBackpressureException;
const-string v1, "Could not emit value due to lack of requests"
invoke-direct {v0, v1}, Lio/reactivex/exceptions/MissingBackpressureException;-><init>(Ljava/lang/String;)V
invoke-interface {p1, v0}, Lf/b/c;->onError(Ljava/lang/Throwable;)V
:goto_2b
return-void
.end method
.method public request(J)V
.registers 4
.line 1
invoke-static {p1, p2}, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->validate(J)Z
move-result v0
if-eqz v0, :cond_9
.line 2
invoke-static {p0, p1, p2}, Lio/reactivex/internal/util/b;->b(Ljava/util/concurrent/atomic/AtomicLong;J)J
:cond_9
return-void
.end method