.class final Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber; .super Ljava/util/concurrent/atomic/AtomicReference; .source "FlowableSequenceEqual.java" # interfaces .implements Lkh/o; # annotations .annotation system Ldalvik/annotation/EnclosingClass; value = Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual; .end annotation .annotation system Ldalvik/annotation/InnerClass; accessFlags = 0x19 name = "EqualSubscriber" .end annotation .annotation system Ldalvik/annotation/Signature; value = { "", "Ljava/util/concurrent/atomic/AtomicReference<", "Lok/e;", ">;", "Lkh/o<", "TT;>;" } .end annotation # static fields .field private static final serialVersionUID:J = 0x42abb13cc59281abL # instance fields .field public volatile done:Z .field public final limit:I .field public final parent:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$a; .field public final prefetch:I .field public produced:J .field public volatile queue:Lrh/o; .annotation system Ldalvik/annotation/Signature; value = { "Lrh/o<", "TT;>;" } .end annotation .end field .field public sourceMode:I # direct methods .method public constructor (Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$a;I)V .locals 0 .line 1 invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicReference;->()V .line 2 iput-object p1, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->parent:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$a; shr-int/lit8 p1, p2, 0x2 sub-int p1, p2, p1 .line 3 iput p1, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->limit:I .line 4 iput p2, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->prefetch:I return-void .end method # virtual methods .method public cancel()V .locals 0 .line 1 invoke-static {p0}, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->cancel(Ljava/util/concurrent/atomic/AtomicReference;)Z return-void .end method .method public clear()V .locals 1 .line 1 iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->queue:Lrh/o; if-eqz v0, :cond_0 .line 2 invoke-interface {v0}, Lrh/o;->clear()V :cond_0 return-void .end method .method public onComplete()V .locals 1 const/4 v0, 0x1 .line 1 iput-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->done:Z .line 2 iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->parent:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$a; invoke-interface {v0}, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$a;->drain()V return-void .end method .method public onError(Ljava/lang/Throwable;)V .locals 1 .line 1 iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->parent:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$a; invoke-interface {v0, p1}, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$a;->innerError(Ljava/lang/Throwable;)V return-void .end method .method public onNext(Ljava/lang/Object;)V .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(TT;)V" } .end annotation .line 1 iget v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->sourceMode:I if-nez v0, :cond_0 .line 2 iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->queue:Lrh/o; invoke-interface {v0, p1}, Lrh/o;->offer(Ljava/lang/Object;)Z move-result p1 if-nez p1, :cond_0 .line 3 new-instance p1, Lio/reactivex/exceptions/MissingBackpressureException; invoke-direct {p1}, Lio/reactivex/exceptions/MissingBackpressureException;->()V invoke-virtual {p0, p1}, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->onError(Ljava/lang/Throwable;)V return-void .line 4 :cond_0 iget-object p1, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->parent:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$a; invoke-interface {p1}, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$a;->drain()V return-void .end method .method public onSubscribe(Lok/e;)V .locals 3 .line 1 invoke-static {p0, p1}, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->setOnce(Ljava/util/concurrent/atomic/AtomicReference;Lok/e;)Z move-result v0 if-eqz v0, :cond_2 .line 2 instance-of v0, p1, Lrh/l; if-eqz v0, :cond_1 .line 3 move-object v0, p1 check-cast v0, Lrh/l; const/4 v1, 0x3 .line 4 invoke-interface {v0, v1}, Lrh/k;->requestFusion(I)I move-result v1 const/4 v2, 0x1 if-ne v1, v2, :cond_0 .line 5 iput v1, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->sourceMode:I .line 6 iput-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->queue:Lrh/o; .line 7 iput-boolean v2, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->done:Z .line 8 iget-object p1, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->parent:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$a; invoke-interface {p1}, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$a;->drain()V return-void :cond_0 const/4 v2, 0x2 if-ne v1, v2, :cond_1 .line 9 iput v1, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->sourceMode:I .line 10 iput-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->queue:Lrh/o; .line 11 iget v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->prefetch:I int-to-long v0, v0 invoke-interface {p1, v0, v1}, Lok/e;->request(J)V return-void .line 12 :cond_1 new-instance v0, Lio/reactivex/internal/queue/SpscArrayQueue; iget v1, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->prefetch:I invoke-direct {v0, v1}, Lio/reactivex/internal/queue/SpscArrayQueue;->(I)V iput-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->queue:Lrh/o; .line 13 iget v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->prefetch:I int-to-long v0, v0 invoke-interface {p1, v0, v1}, Lok/e;->request(J)V :cond_2 return-void .end method .method public request()V .locals 4 .line 1 iget v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->sourceMode:I const/4 v1, 0x1 if-eq v0, v1, :cond_1 .line 2 iget-wide v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->produced:J const-wide/16 v2, 0x1 add-long/2addr v0, v2 .line 3 iget v2, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->limit:I int-to-long v2, v2 cmp-long v2, v0, v2 if-ltz v2, :cond_0 const-wide/16 v2, 0x0 .line 4 iput-wide v2, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->produced:J .line 5 invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object v2 check-cast v2, Lok/e; invoke-interface {v2, v0, v1}, Lok/e;->request(J)V goto :goto_0 .line 6 :cond_0 iput-wide v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;->produced:J :cond_1 :goto_0 return-void .end method