.class public final Lr0/q/a$d; .super Ljava/lang/Object; .source "ReplaySubject.java" # interfaces .implements Lr0/q/a$a; # annotations .annotation system Ldalvik/annotation/EnclosingClass; value = Lr0/q/a; .end annotation .annotation system Ldalvik/annotation/InnerClass; accessFlags = 0x19 name = "d" .end annotation .annotation system Ldalvik/annotation/Signature; value = { "", "Ljava/lang/Object;", "Lr0/q/a$a<", "TT;>;" } .end annotation # instance fields .field public final a:I .field public volatile b:I .field public final c:[Ljava/lang/Object; .field public d:[Ljava/lang/Object; .field public e:I .field public volatile f:Z .field public g:Ljava/lang/Throwable; # direct methods .method public constructor (I)V .locals 0 invoke-direct {p0}, Ljava/lang/Object;->()V iput p1, p0, Lr0/q/a$d;->a:I add-int/lit8 p1, p1, 0x1 new-array p1, p1, [Ljava/lang/Object; iput-object p1, p0, Lr0/q/a$d;->c:[Ljava/lang/Object; iput-object p1, p0, Lr0/q/a$d;->d:[Ljava/lang/Object; return-void .end method # virtual methods .method public a(Lr0/q/a$b;)V .locals 19 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lr0/q/a$b<", "TT;>;)V" } .end annotation move-object/from16 v0, p0 move-object/from16 v1, p1 invoke-virtual/range {p1 .. p1}, Ljava/util/concurrent/atomic/AtomicInteger;->getAndIncrement()I move-result v2 if-eqz v2, :cond_0 return-void :cond_0 iget-object v2, v1, Lr0/q/a$b;->actual:Lrx/Subscriber; iget v3, v0, Lr0/q/a$d;->a:I const/4 v4, 0x1 const/4 v5, 0x1 :cond_1 iget-object v6, v1, Lr0/q/a$b;->requested:Ljava/util/concurrent/atomic/AtomicLong; invoke-virtual {v6}, Ljava/util/concurrent/atomic/AtomicLong;->get()J move-result-wide v6 iget-object v8, v1, Lr0/q/a$b;->node:Ljava/lang/Object; check-cast v8, [Ljava/lang/Object; if-nez v8, :cond_2 iget-object v8, v0, Lr0/q/a$d;->c:[Ljava/lang/Object; :cond_2 iget v9, v1, Lr0/q/a$b;->tailIndex:I iget v10, v1, Lr0/q/a$b;->index:I const-wide/16 v13, 0x0 :goto_0 const/4 v15, 0x0 cmp-long v17, v13, v6 if-eqz v17, :cond_9 invoke-virtual {v2}, Lrx/Subscriber;->isUnsubscribed()Z move-result v18 if-eqz v18, :cond_3 iput-object v15, v1, Lr0/q/a$b;->node:Ljava/lang/Object; return-void :cond_3 iget-boolean v11, v0, Lr0/q/a$d;->f:Z iget v12, v0, Lr0/q/a$d;->b:I if-ne v10, v12, :cond_4 const/4 v12, 0x1 goto :goto_1 :cond_4 const/4 v12, 0x0 :goto_1 if-eqz v11, :cond_6 if-eqz v12, :cond_6 iput-object v15, v1, Lr0/q/a$b;->node:Ljava/lang/Object; iget-object v1, v0, Lr0/q/a$d;->g:Ljava/lang/Throwable; if-eqz v1, :cond_5 invoke-interface {v2, v1}, Lr0/g;->onError(Ljava/lang/Throwable;)V goto :goto_2 :cond_5 invoke-interface {v2}, Lr0/g;->onCompleted()V :goto_2 return-void :cond_6 if-eqz v12, :cond_7 goto :goto_3 :cond_7 if-ne v9, v3, :cond_8 aget-object v8, v8, v9 check-cast v8, [Ljava/lang/Object; const/4 v9, 0x0 :cond_8 aget-object v11, v8, v9 invoke-interface {v2, v11}, Lr0/g;->onNext(Ljava/lang/Object;)V const-wide/16 v11, 0x1 add-long/2addr v13, v11 add-int/2addr v9, v4 add-int/lit8 v10, v10, 0x1 goto :goto_0 :cond_9 :goto_3 if-nez v17, :cond_d invoke-virtual {v2}, Lrx/Subscriber;->isUnsubscribed()Z move-result v11 if-eqz v11, :cond_a iput-object v15, v1, Lr0/q/a$b;->node:Ljava/lang/Object; return-void :cond_a iget-boolean v11, v0, Lr0/q/a$d;->f:Z iget v12, v0, Lr0/q/a$d;->b:I if-ne v10, v12, :cond_b const/16 v16, 0x1 goto :goto_4 :cond_b const/16 v16, 0x0 :goto_4 if-eqz v11, :cond_d if-eqz v16, :cond_d iput-object v15, v1, Lr0/q/a$b;->node:Ljava/lang/Object; iget-object v1, v0, Lr0/q/a$d;->g:Ljava/lang/Throwable; if-eqz v1, :cond_c invoke-interface {v2, v1}, Lr0/g;->onError(Ljava/lang/Throwable;)V goto :goto_5 :cond_c invoke-interface {v2}, Lr0/g;->onCompleted()V :goto_5 return-void :cond_d const-wide/16 v11, 0x0 cmp-long v15, v13, v11 if-eqz v15, :cond_e const-wide v11, 0x7fffffffffffffffL cmp-long v15, v6, v11 if-eqz v15, :cond_e iget-object v6, v1, Lr0/q/a$b;->requested:Ljava/util/concurrent/atomic/AtomicLong; invoke-static {v6, v13, v14}, Lj0/i/u;->J(Ljava/util/concurrent/atomic/AtomicLong;J)J :cond_e iput v10, v1, Lr0/q/a$b;->index:I iput v9, v1, Lr0/q/a$b;->tailIndex:I iput-object v8, v1, Lr0/q/a$b;->node:Ljava/lang/Object; neg-int v5, v5 invoke-virtual {v1, v5}, Ljava/util/concurrent/atomic/AtomicInteger;->addAndGet(I)I move-result v5 if-nez v5, :cond_1 return-void .end method