.class public Lio/reactivex/subscribers/TestSubscriber; .super Lio/reactivex/observers/BaseTestConsumer; .source "TestSubscriber.java" # interfaces .implements Lorg/reactivestreams/Subscriber; .implements Lorg/reactivestreams/Subscription; .implements Lio/reactivex/disposables/Disposable; # annotations .annotation system Ldalvik/annotation/MemberClasses; value = { Lio/reactivex/subscribers/TestSubscriber$EmptySubscriber; } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "", "Lio/reactivex/observers/BaseTestConsumer<", "TT;", "Lio/reactivex/subscribers/TestSubscriber<", "TT;>;>;", "Lorg/reactivestreams/Subscriber<", "TT;>;", "Lorg/reactivestreams/Subscription;", "Lio/reactivex/disposables/Disposable;" } .end annotation # instance fields .field private final actual:Lorg/reactivestreams/Subscriber; .annotation system Ldalvik/annotation/Signature; value = { "Lorg/reactivestreams/Subscriber<", "-TT;>;" } .end annotation .end field .field private volatile cancelled:Z .field private final missedRequested:Ljava/util/concurrent/atomic/AtomicLong; .field private qs:Lio/reactivex/internal/fuseable/QueueSubscription; .annotation system Ldalvik/annotation/Signature; value = { "Lio/reactivex/internal/fuseable/QueueSubscription<", "TT;>;" } .end annotation .end field .field private final subscription:Ljava/util/concurrent/atomic/AtomicReference; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/util/concurrent/atomic/AtomicReference<", "Lorg/reactivestreams/Subscription;", ">;" } .end annotation .end field # direct methods .method public constructor ()V .locals 3 .line 90 sget-object v0, Lio/reactivex/subscribers/TestSubscriber$EmptySubscriber;->INSTANCE:Lio/reactivex/subscribers/TestSubscriber$EmptySubscriber; const-wide v1, 0x7fffffffffffffffL invoke-direct {p0, v0, v1, v2}, Lio/reactivex/subscribers/TestSubscriber;->(Lorg/reactivestreams/Subscriber;J)V return-void .end method .method public constructor (J)V .locals 1 .line 100 sget-object v0, Lio/reactivex/subscribers/TestSubscriber$EmptySubscriber;->INSTANCE:Lio/reactivex/subscribers/TestSubscriber$EmptySubscriber; invoke-direct {p0, v0, p1, p2}, Lio/reactivex/subscribers/TestSubscriber;->(Lorg/reactivestreams/Subscriber;J)V return-void .end method .method public constructor (Lorg/reactivestreams/Subscriber;)V .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Subscriber<", "-TT;>;)V" } .end annotation const-wide v0, 0x7fffffffffffffffL .line 108 invoke-direct {p0, p1, v0, v1}, Lio/reactivex/subscribers/TestSubscriber;->(Lorg/reactivestreams/Subscriber;J)V return-void .end method .method public constructor (Lorg/reactivestreams/Subscriber;J)V .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Subscriber<", "-TT;>;J)V" } .end annotation .line 119 invoke-direct {p0}, Lio/reactivex/observers/BaseTestConsumer;->()V .line 120 iput-object p1, p0, Lio/reactivex/subscribers/TestSubscriber;->actual:Lorg/reactivestreams/Subscriber; .line 121 new-instance p1, Ljava/util/concurrent/atomic/AtomicReference; invoke-direct {p1}, Ljava/util/concurrent/atomic/AtomicReference;->()V iput-object p1, p0, Lio/reactivex/subscribers/TestSubscriber;->subscription:Ljava/util/concurrent/atomic/AtomicReference; .line 122 new-instance p1, Ljava/util/concurrent/atomic/AtomicLong; invoke-direct {p1, p2, p3}, Ljava/util/concurrent/atomic/AtomicLong;->(J)V iput-object p1, p0, Lio/reactivex/subscribers/TestSubscriber;->missedRequested:Ljava/util/concurrent/atomic/AtomicLong; return-void .end method .method public static create()Lio/reactivex/subscribers/TestSubscriber; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/subscribers/TestSubscriber<", "TT;>;" } .end annotation .line 63 new-instance v0, Lio/reactivex/subscribers/TestSubscriber; invoke-direct {v0}, Lio/reactivex/subscribers/TestSubscriber;->()V return-object v0 .end method .method public static create(J)Lio/reactivex/subscribers/TestSubscriber; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J)", "Lio/reactivex/subscribers/TestSubscriber<", "TT;>;" } .end annotation .line 73 new-instance v0, Lio/reactivex/subscribers/TestSubscriber; invoke-direct {v0, p0, p1}, Lio/reactivex/subscribers/TestSubscriber;->(J)V return-object v0 .end method .method public static create(Lorg/reactivestreams/Subscriber;)Lio/reactivex/subscribers/TestSubscriber; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lorg/reactivestreams/Subscriber<", "-TT;>;)", "Lio/reactivex/subscribers/TestSubscriber<", "TT;>;" } .end annotation .line 83 new-instance v0, Lio/reactivex/subscribers/TestSubscriber; invoke-direct {v0, p0}, Lio/reactivex/subscribers/TestSubscriber;->(Lorg/reactivestreams/Subscriber;)V return-object v0 .end method .method static fusionModeToString(I)Ljava/lang/String; .locals 2 if-eqz p0, :cond_2 const/4 v0, 0x1 if-eq p0, v0, :cond_1 const/4 v0, 0x2 if-eq p0, v0, :cond_0 .line 363 new-instance v0, Ljava/lang/StringBuilder; invoke-direct {v0}, Ljava/lang/StringBuilder;->()V const-string v1, "Unknown(" invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v0, p0}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; const-string p0, ")" invoke-virtual {v0, p0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p0 return-object p0 :cond_0 const-string p0, "ASYNC" return-object p0 :cond_1 const-string p0, "SYNC" return-object p0 :cond_2 const-string p0, "NONE" return-object p0 .end method # virtual methods .method final assertFuseable()Lio/reactivex/subscribers/TestSubscriber; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/subscribers/TestSubscriber<", "TT;>;" } .end annotation .line 374 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->qs:Lio/reactivex/internal/fuseable/QueueSubscription; if-eqz v0, :cond_0 return-object p0 .line 375 :cond_0 new-instance v0, Ljava/lang/AssertionError; const-string v1, "Upstream is not fuseable." invoke-direct {v0, v1}, Ljava/lang/AssertionError;->(Ljava/lang/Object;)V throw v0 .end method .method final assertFusionMode(I)Lio/reactivex/subscribers/TestSubscriber; .locals 4 .annotation system Ldalvik/annotation/Signature; value = { "(I)", "Lio/reactivex/subscribers/TestSubscriber<", "TT;>;" } .end annotation .line 346 iget v0, p0, Lio/reactivex/subscribers/TestSubscriber;->establishedFusionMode:I if-eq v0, p1, :cond_1 .line 348 iget-object v1, p0, Lio/reactivex/subscribers/TestSubscriber;->qs:Lio/reactivex/internal/fuseable/QueueSubscription; if-eqz v1, :cond_0 .line 349 new-instance v1, Ljava/lang/AssertionError; new-instance v2, Ljava/lang/StringBuilder; invoke-direct {v2}, Ljava/lang/StringBuilder;->()V const-string v3, "Fusion mode different. Expected: " invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-static {p1}, Lio/reactivex/subscribers/TestSubscriber;->fusionModeToString(I)Ljava/lang/String; move-result-object p1 invoke-virtual {v2, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; const-string p1, ", actual: " invoke-virtual {v2, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-static {v0}, Lio/reactivex/subscribers/TestSubscriber;->fusionModeToString(I)Ljava/lang/String; move-result-object p1 invoke-virtual {v2, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p1 invoke-direct {v1, p1}, Ljava/lang/AssertionError;->(Ljava/lang/Object;)V throw v1 :cond_0 const-string p1, "Upstream is not fuseable" .line 352 invoke-virtual {p0, p1}, Lio/reactivex/subscribers/TestSubscriber;->fail(Ljava/lang/String;)Ljava/lang/AssertionError; move-result-object p1 throw p1 :cond_1 return-object p0 .end method .method final assertNotFuseable()Lio/reactivex/subscribers/TestSubscriber; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/subscribers/TestSubscriber<", "TT;>;" } .end annotation .line 387 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->qs:Lio/reactivex/internal/fuseable/QueueSubscription; if-nez v0, :cond_0 return-object p0 .line 388 :cond_0 new-instance v0, Ljava/lang/AssertionError; const-string v1, "Upstream is fuseable." invoke-direct {v0, v1}, Ljava/lang/AssertionError;->(Ljava/lang/Object;)V throw v0 .end method .method public bridge synthetic assertNotSubscribed()Lio/reactivex/observers/BaseTestConsumer; .locals 1 .line 40 invoke-virtual {p0}, Lio/reactivex/subscribers/TestSubscriber;->assertNotSubscribed()Lio/reactivex/subscribers/TestSubscriber; move-result-object v0 return-object v0 .end method .method public final assertNotSubscribed()Lio/reactivex/subscribers/TestSubscriber; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/subscribers/TestSubscriber<", "TT;>;" } .end annotation .line 317 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->subscription:Ljava/util/concurrent/atomic/AtomicReference; invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object v0 if-nez v0, :cond_1 .line 320 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->errors:Ljava/util/List; invoke-interface {v0}, Ljava/util/List;->isEmpty()Z move-result v0 if-eqz v0, :cond_0 return-object p0 :cond_0 const-string v0, "Not subscribed but errors found" .line 321 invoke-virtual {p0, v0}, Lio/reactivex/subscribers/TestSubscriber;->fail(Ljava/lang/String;)Ljava/lang/AssertionError; move-result-object v0 throw v0 :cond_1 const-string v0, "Subscribed!" .line 318 invoke-virtual {p0, v0}, Lio/reactivex/subscribers/TestSubscriber;->fail(Ljava/lang/String;)Ljava/lang/AssertionError; move-result-object v0 throw v0 .end method .method public final assertOf(Lio/reactivex/functions/Consumer;)Lio/reactivex/subscribers/TestSubscriber; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lio/reactivex/functions/Consumer<", "-", "Lio/reactivex/subscribers/TestSubscriber<", "TT;>;>;)", "Lio/reactivex/subscribers/TestSubscriber<", "TT;>;" } .end annotation .line 400 :try_start_0 invoke-interface {p1, p0}, Lio/reactivex/functions/Consumer;->accept(Ljava/lang/Object;)V :try_end_0 .catch Ljava/lang/Throwable; {:try_start_0 .. :try_end_0} :catch_0 return-object p0 :catch_0 move-exception p1 .line 402 invoke-static {p1}, Lio/reactivex/internal/util/ExceptionHelper;->wrapOrThrow(Ljava/lang/Throwable;)Ljava/lang/RuntimeException; move-result-object p1 throw p1 .end method .method public bridge synthetic assertSubscribed()Lio/reactivex/observers/BaseTestConsumer; .locals 1 .line 40 invoke-virtual {p0}, Lio/reactivex/subscribers/TestSubscriber;->assertSubscribed()Lio/reactivex/subscribers/TestSubscriber; move-result-object v0 return-object v0 .end method .method public final assertSubscribed()Lio/reactivex/subscribers/TestSubscriber; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/subscribers/TestSubscriber<", "TT;>;" } .end annotation .line 305 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->subscription:Ljava/util/concurrent/atomic/AtomicReference; invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object v0 if-eqz v0, :cond_0 return-object p0 :cond_0 const-string v0, "Not subscribed!" .line 306 invoke-virtual {p0, v0}, Lio/reactivex/subscribers/TestSubscriber;->fail(Ljava/lang/String;)Ljava/lang/AssertionError; move-result-object v0 throw v0 .end method .method public final cancel()V .locals 1 .line 263 iget-boolean v0, p0, Lio/reactivex/subscribers/TestSubscriber;->cancelled:Z if-nez v0, :cond_0 const/4 v0, 0x1 .line 264 iput-boolean v0, p0, Lio/reactivex/subscribers/TestSubscriber;->cancelled:Z .line 265 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->subscription:Ljava/util/concurrent/atomic/AtomicReference; invoke-static {v0}, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->cancel(Ljava/util/concurrent/atomic/AtomicReference;)Z :cond_0 return-void .end method .method public final dispose()V .locals 0 .line 279 invoke-virtual {p0}, Lio/reactivex/subscribers/TestSubscriber;->cancel()V return-void .end method .method public final hasSubscription()Z .locals 1 .line 294 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->subscription:Ljava/util/concurrent/atomic/AtomicReference; invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object v0 if-eqz v0, :cond_0 const/4 v0, 0x1 goto :goto_0 :cond_0 const/4 v0, 0x0 :goto_0 return v0 .end method .method public final isCancelled()Z .locals 1 .line 274 iget-boolean v0, p0, Lio/reactivex/subscribers/TestSubscriber;->cancelled:Z return v0 .end method .method public final isDisposed()Z .locals 1 .line 284 iget-boolean v0, p0, Lio/reactivex/subscribers/TestSubscriber;->cancelled:Z return v0 .end method .method public onComplete()V .locals 4 .line 240 iget-boolean v0, p0, Lio/reactivex/subscribers/TestSubscriber;->checkSubscriptionOnce:Z if-nez v0, :cond_0 const/4 v0, 0x1 .line 241 iput-boolean v0, p0, Lio/reactivex/subscribers/TestSubscriber;->checkSubscriptionOnce:Z .line 242 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->subscription:Ljava/util/concurrent/atomic/AtomicReference; invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object v0 if-nez v0, :cond_0 .line 243 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->errors:Ljava/util/List; new-instance v1, Ljava/lang/IllegalStateException; const-string v2, "onSubscribe not called in proper order" invoke-direct {v1, v2}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V invoke-interface {v0, v1}, Ljava/util/List;->add(Ljava/lang/Object;)Z .line 247 :cond_0 :try_start_0 invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread; move-result-object v0 iput-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->lastThread:Ljava/lang/Thread; .line 248 iget-wide v0, p0, Lio/reactivex/subscribers/TestSubscriber;->completions:J const-wide/16 v2, 0x1 add-long/2addr v0, v2 iput-wide v0, p0, Lio/reactivex/subscribers/TestSubscriber;->completions:J .line 250 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->actual:Lorg/reactivestreams/Subscriber; invoke-interface {v0}, Lorg/reactivestreams/Subscriber;->onComplete()V :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 .line 252 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->done:Ljava/util/concurrent/CountDownLatch; invoke-virtual {v0}, Ljava/util/concurrent/CountDownLatch;->countDown()V return-void :catchall_0 move-exception v0 iget-object v1, p0, Lio/reactivex/subscribers/TestSubscriber;->done:Ljava/util/concurrent/CountDownLatch; invoke-virtual {v1}, Ljava/util/concurrent/CountDownLatch;->countDown()V throw v0 .end method .method public onError(Ljava/lang/Throwable;)V .locals 3 .line 218 iget-boolean v0, p0, Lio/reactivex/subscribers/TestSubscriber;->checkSubscriptionOnce:Z if-nez v0, :cond_0 const/4 v0, 0x1 .line 219 iput-boolean v0, p0, Lio/reactivex/subscribers/TestSubscriber;->checkSubscriptionOnce:Z .line 220 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->subscription:Ljava/util/concurrent/atomic/AtomicReference; invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object v0 if-nez v0, :cond_0 .line 221 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->errors:Ljava/util/List; new-instance v1, Ljava/lang/NullPointerException; const-string v2, "onSubscribe not called in proper order" invoke-direct {v1, v2}, Ljava/lang/NullPointerException;->(Ljava/lang/String;)V invoke-interface {v0, v1}, Ljava/util/List;->add(Ljava/lang/Object;)Z .line 225 :cond_0 :try_start_0 invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread; move-result-object v0 iput-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->lastThread:Ljava/lang/Thread; .line 226 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->errors:Ljava/util/List; invoke-interface {v0, p1}, Ljava/util/List;->add(Ljava/lang/Object;)Z if-nez p1, :cond_1 .line 229 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->errors:Ljava/util/List; new-instance v1, Ljava/lang/IllegalStateException; const-string v2, "onError received a null Throwable" invoke-direct {v1, v2}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V invoke-interface {v0, v1}, Ljava/util/List;->add(Ljava/lang/Object;)Z .line 232 :cond_1 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->actual:Lorg/reactivestreams/Subscriber; invoke-interface {v0, p1}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 .line 234 iget-object p1, p0, Lio/reactivex/subscribers/TestSubscriber;->done:Ljava/util/concurrent/CountDownLatch; invoke-virtual {p1}, Ljava/util/concurrent/CountDownLatch;->countDown()V return-void :catchall_0 move-exception p1 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->done:Ljava/util/concurrent/CountDownLatch; invoke-virtual {v0}, Ljava/util/concurrent/CountDownLatch;->countDown()V throw p1 .end method .method public onNext(Ljava/lang/Object;)V .locals 3 .annotation system Ldalvik/annotation/Signature; value = { "(TT;)V" } .end annotation .line 187 iget-boolean v0, p0, Lio/reactivex/subscribers/TestSubscriber;->checkSubscriptionOnce:Z if-nez v0, :cond_0 const/4 v0, 0x1 .line 188 iput-boolean v0, p0, Lio/reactivex/subscribers/TestSubscriber;->checkSubscriptionOnce:Z .line 189 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->subscription:Ljava/util/concurrent/atomic/AtomicReference; invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object v0 if-nez v0, :cond_0 .line 190 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->errors:Ljava/util/List; new-instance v1, Ljava/lang/IllegalStateException; const-string v2, "onSubscribe not called in proper order" invoke-direct {v1, v2}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V invoke-interface {v0, v1}, Ljava/util/List;->add(Ljava/lang/Object;)Z .line 193 :cond_0 invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread; move-result-object v0 iput-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->lastThread:Ljava/lang/Thread; .line 195 iget v0, p0, Lio/reactivex/subscribers/TestSubscriber;->establishedFusionMode:I const/4 v1, 0x2 if-ne v0, v1, :cond_2 .line 197 :goto_0 :try_start_0 iget-object p1, p0, Lio/reactivex/subscribers/TestSubscriber;->qs:Lio/reactivex/internal/fuseable/QueueSubscription; invoke-interface {p1}, Lio/reactivex/internal/fuseable/QueueSubscription;->poll()Ljava/lang/Object; move-result-object p1 if-eqz p1, :cond_1 .line 198 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->values:Ljava/util/List; invoke-interface {v0, p1}, Ljava/util/List;->add(Ljava/lang/Object;)Z :try_end_0 .catch Ljava/lang/Throwable; {:try_start_0 .. :try_end_0} :catch_0 goto :goto_0 :catch_0 move-exception p1 .line 202 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->errors:Ljava/util/List; invoke-interface {v0, p1}, Ljava/util/List;->add(Ljava/lang/Object;)Z :cond_1 return-void .line 207 :cond_2 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->values:Ljava/util/List; invoke-interface {v0, p1}, Ljava/util/List;->add(Ljava/lang/Object;)Z if-nez p1, :cond_3 .line 210 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->errors:Ljava/util/List; new-instance v1, Ljava/lang/NullPointerException; const-string v2, "onNext received a null value" invoke-direct {v1, v2}, Ljava/lang/NullPointerException;->(Ljava/lang/String;)V invoke-interface {v0, v1}, Ljava/util/List;->add(Ljava/lang/Object;)Z .line 213 :cond_3 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->actual:Lorg/reactivestreams/Subscriber; invoke-interface {v0, p1}, Lorg/reactivestreams/Subscriber;->onNext(Ljava/lang/Object;)V return-void .end method .method protected onStart()V .locals 0 return-void .end method .method public onSubscribe(Lorg/reactivestreams/Subscription;)V .locals 5 .line 128 invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread; move-result-object v0 iput-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->lastThread:Ljava/lang/Thread; if-nez p1, :cond_0 .line 131 iget-object p1, p0, Lio/reactivex/subscribers/TestSubscriber;->errors:Ljava/util/List; new-instance v0, Ljava/lang/NullPointerException; const-string v1, "onSubscribe received a null Subscription" invoke-direct {v0, v1}, Ljava/lang/NullPointerException;->(Ljava/lang/String;)V invoke-interface {p1, v0}, Ljava/util/List;->add(Ljava/lang/Object;)Z return-void .line 134 :cond_0 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->subscription:Ljava/util/concurrent/atomic/AtomicReference; const/4 v1, 0x0 invoke-virtual {v0, v1, p1}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z move-result v0 if-nez v0, :cond_2 .line 135 invoke-interface {p1}, Lorg/reactivestreams/Subscription;->cancel()V .line 136 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->subscription:Ljava/util/concurrent/atomic/AtomicReference; invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object v0 sget-object v1, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->CANCELLED:Lio/reactivex/internal/subscriptions/SubscriptionHelper; if-eq v0, v1, :cond_1 .line 137 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->errors:Ljava/util/List; new-instance v1, Ljava/lang/IllegalStateException; new-instance v2, Ljava/lang/StringBuilder; invoke-direct {v2}, Ljava/lang/StringBuilder;->()V const-string v3, "onSubscribe received multiple subscriptions: " invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v2, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p1 invoke-direct {v1, p1}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V invoke-interface {v0, v1}, Ljava/util/List;->add(Ljava/lang/Object;)Z :cond_1 return-void .line 142 :cond_2 iget v0, p0, Lio/reactivex/subscribers/TestSubscriber;->initialFusionMode:I if-eqz v0, :cond_4 .line 143 instance-of v0, p1, Lio/reactivex/internal/fuseable/QueueSubscription; if-eqz v0, :cond_4 .line 144 move-object v0, p1 check-cast v0, Lio/reactivex/internal/fuseable/QueueSubscription; iput-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->qs:Lio/reactivex/internal/fuseable/QueueSubscription; .line 146 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->qs:Lio/reactivex/internal/fuseable/QueueSubscription; iget v1, p0, Lio/reactivex/subscribers/TestSubscriber;->initialFusionMode:I invoke-interface {v0, v1}, Lio/reactivex/internal/fuseable/QueueSubscription;->requestFusion(I)I move-result v0 .line 147 iput v0, p0, Lio/reactivex/subscribers/TestSubscriber;->establishedFusionMode:I const/4 v1, 0x1 if-ne v0, v1, :cond_4 .line 150 iput-boolean v1, p0, Lio/reactivex/subscribers/TestSubscriber;->checkSubscriptionOnce:Z .line 151 invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread; move-result-object p1 iput-object p1, p0, Lio/reactivex/subscribers/TestSubscriber;->lastThread:Ljava/lang/Thread; .line 154 :goto_0 :try_start_0 iget-object p1, p0, Lio/reactivex/subscribers/TestSubscriber;->qs:Lio/reactivex/internal/fuseable/QueueSubscription; invoke-interface {p1}, Lio/reactivex/internal/fuseable/QueueSubscription;->poll()Ljava/lang/Object; move-result-object p1 if-eqz p1, :cond_3 .line 155 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->values:Ljava/util/List; invoke-interface {v0, p1}, Ljava/util/List;->add(Ljava/lang/Object;)Z goto :goto_0 .line 157 :cond_3 iget-wide v0, p0, Lio/reactivex/subscribers/TestSubscriber;->completions:J const-wide/16 v2, 0x1 add-long/2addr v0, v2 iput-wide v0, p0, Lio/reactivex/subscribers/TestSubscriber;->completions:J :try_end_0 .catch Ljava/lang/Throwable; {:try_start_0 .. :try_end_0} :catch_0 goto :goto_1 :catch_0 move-exception p1 .line 160 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->errors:Ljava/util/List; invoke-interface {v0, p1}, Ljava/util/List;->add(Ljava/lang/Object;)Z :goto_1 return-void .line 168 :cond_4 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->actual:Lorg/reactivestreams/Subscriber; invoke-interface {v0, p1}, Lorg/reactivestreams/Subscriber;->onSubscribe(Lorg/reactivestreams/Subscription;)V .line 170 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->missedRequested:Ljava/util/concurrent/atomic/AtomicLong; const-wide/16 v1, 0x0 invoke-virtual {v0, v1, v2}, Ljava/util/concurrent/atomic/AtomicLong;->getAndSet(J)J move-result-wide v3 cmp-long v0, v3, v1 if-eqz v0, :cond_5 .line 172 invoke-interface {p1, v3, v4}, Lorg/reactivestreams/Subscription;->request(J)V .line 175 :cond_5 invoke-virtual {p0}, Lio/reactivex/subscribers/TestSubscriber;->onStart()V return-void .end method .method public final request(J)V .locals 2 .line 258 iget-object v0, p0, Lio/reactivex/subscribers/TestSubscriber;->subscription:Ljava/util/concurrent/atomic/AtomicReference; iget-object v1, p0, Lio/reactivex/subscribers/TestSubscriber;->missedRequested:Ljava/util/concurrent/atomic/AtomicLong; invoke-static {v0, v1, p1, p2}, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->deferredRequest(Ljava/util/concurrent/atomic/AtomicReference;Ljava/util/concurrent/atomic/AtomicLong;J)V return-void .end method .method public final requestMore(J)Lio/reactivex/subscribers/TestSubscriber; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(J)", "Lio/reactivex/subscribers/TestSubscriber<", "TT;>;" } .end annotation .annotation build Lio/reactivex/annotations/Experimental; .end annotation .line 415 invoke-virtual {p0, p1, p2}, Lio/reactivex/subscribers/TestSubscriber;->request(J)V return-object p0 .end method .method final setInitialFusionMode(I)Lio/reactivex/subscribers/TestSubscriber; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(I)", "Lio/reactivex/subscribers/TestSubscriber<", "TT;>;" } .end annotation .line 334 iput p1, p0, Lio/reactivex/subscribers/TestSubscriber;->initialFusionMode:I return-object p0 .end method