123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276 |
- .class public final Lio/reactivex/internal/observers/InnerQueuedObserver;
- .super Ljava/util/concurrent/atomic/AtomicReference;
- .source "InnerQueuedObserver.java"
- # interfaces
- .implements Lio/reactivex/Observer;
- .implements Lio/reactivex/disposables/Disposable;
- # annotations
- .annotation system Ldalvik/annotation/Signature;
- value = {
- "<T:",
- "Ljava/lang/Object;",
- ">",
- "Ljava/util/concurrent/atomic/AtomicReference<",
- "Lio/reactivex/disposables/Disposable;",
- ">;",
- "Lio/reactivex/Observer<",
- "TT;>;",
- "Lio/reactivex/disposables/Disposable;"
- }
- .end annotation
- # static fields
- .field private static final serialVersionUID:J = -0x4b2db39073b2fa8dL
- # instance fields
- .field volatile done:Z
- .field fusionMode:I
- .field final parent:Lio/reactivex/internal/observers/InnerQueuedObserverSupport;
- .annotation system Ldalvik/annotation/Signature;
- value = {
- "Lio/reactivex/internal/observers/InnerQueuedObserverSupport<",
- "TT;>;"
- }
- .end annotation
- .end field
- .field final prefetch:I
- .field queue:Lio/reactivex/internal/fuseable/SimpleQueue;
- .annotation system Ldalvik/annotation/Signature;
- value = {
- "Lio/reactivex/internal/fuseable/SimpleQueue<",
- "TT;>;"
- }
- .end annotation
- .end field
- # direct methods
- .method public constructor <init>(Lio/reactivex/internal/observers/InnerQueuedObserverSupport;I)V
- .locals 0
- .annotation system Ldalvik/annotation/Signature;
- value = {
- "(",
- "Lio/reactivex/internal/observers/InnerQueuedObserverSupport<",
- "TT;>;I)V"
- }
- .end annotation
- .line 47
- invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
- .line 48
- iput-object p1, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->parent:Lio/reactivex/internal/observers/InnerQueuedObserverSupport;
- .line 49
- iput p2, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->prefetch:I
- return-void
- .end method
- # virtual methods
- .method public dispose()V
- .locals 0
- .line 99
- invoke-static {p0}, Lio/reactivex/internal/disposables/DisposableHelper;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z
- return-void
- .end method
- .method public fusionMode()I
- .locals 1
- .line 120
- iget v0, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->fusionMode:I
- return v0
- .end method
- .method public isDisposed()Z
- .locals 1
- .line 104
- invoke-virtual {p0}, Lio/reactivex/internal/observers/InnerQueuedObserver;->get()Ljava/lang/Object;
- move-result-object v0
- check-cast v0, Lio/reactivex/disposables/Disposable;
- invoke-static {v0}, Lio/reactivex/internal/disposables/DisposableHelper;->isDisposed(Lio/reactivex/disposables/Disposable;)Z
- move-result v0
- return v0
- .end method
- .method public isDone()Z
- .locals 1
- .line 108
- iget-boolean v0, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->done:Z
- return v0
- .end method
- .method public onComplete()V
- .locals 1
- .line 94
- iget-object v0, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->parent:Lio/reactivex/internal/observers/InnerQueuedObserverSupport;
- invoke-interface {v0, p0}, Lio/reactivex/internal/observers/InnerQueuedObserverSupport;->innerComplete(Lio/reactivex/internal/observers/InnerQueuedObserver;)V
- return-void
- .end method
- .method public onError(Ljava/lang/Throwable;)V
- .locals 1
- .line 89
- iget-object v0, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->parent:Lio/reactivex/internal/observers/InnerQueuedObserverSupport;
- invoke-interface {v0, p0, p1}, Lio/reactivex/internal/observers/InnerQueuedObserverSupport;->innerError(Lio/reactivex/internal/observers/InnerQueuedObserver;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 80
- iget v0, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->fusionMode:I
- if-nez v0, :cond_0
- .line 81
- iget-object v0, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->parent:Lio/reactivex/internal/observers/InnerQueuedObserverSupport;
- invoke-interface {v0, p0, p1}, Lio/reactivex/internal/observers/InnerQueuedObserverSupport;->innerNext(Lio/reactivex/internal/observers/InnerQueuedObserver;Ljava/lang/Object;)V
- goto :goto_0
- .line 83
- :cond_0
- iget-object p1, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->parent:Lio/reactivex/internal/observers/InnerQueuedObserverSupport;
- invoke-interface {p1}, Lio/reactivex/internal/observers/InnerQueuedObserverSupport;->drain()V
- :goto_0
- return-void
- .end method
- .method public onSubscribe(Lio/reactivex/disposables/Disposable;)V
- .locals 2
- .line 54
- invoke-static {p0, p1}, Lio/reactivex/internal/disposables/DisposableHelper;->setOnce(Ljava/util/concurrent/atomic/AtomicReference;Lio/reactivex/disposables/Disposable;)Z
- move-result v0
- if-eqz v0, :cond_2
- .line 55
- instance-of v0, p1, Lio/reactivex/internal/fuseable/QueueDisposable;
- if-eqz v0, :cond_1
- .line 57
- check-cast p1, Lio/reactivex/internal/fuseable/QueueDisposable;
- const/4 v0, 0x3
- .line 59
- invoke-interface {p1, v0}, Lio/reactivex/internal/fuseable/QueueDisposable;->requestFusion(I)I
- move-result v0
- const/4 v1, 0x1
- if-ne v0, v1, :cond_0
- .line 61
- iput v0, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->fusionMode:I
- .line 62
- iput-object p1, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->queue:Lio/reactivex/internal/fuseable/SimpleQueue;
- .line 63
- iput-boolean v1, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->done:Z
- .line 64
- iget-object p1, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->parent:Lio/reactivex/internal/observers/InnerQueuedObserverSupport;
- invoke-interface {p1, p0}, Lio/reactivex/internal/observers/InnerQueuedObserverSupport;->innerComplete(Lio/reactivex/internal/observers/InnerQueuedObserver;)V
- return-void
- :cond_0
- const/4 v1, 0x2
- if-ne v0, v1, :cond_1
- .line 68
- iput v0, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->fusionMode:I
- .line 69
- iput-object p1, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->queue:Lio/reactivex/internal/fuseable/SimpleQueue;
- return-void
- .line 74
- :cond_1
- iget p1, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->prefetch:I
- neg-int p1, p1
- invoke-static {p1}, Lio/reactivex/internal/util/QueueDrainHelper;->createQueue(I)Lio/reactivex/internal/fuseable/SimpleQueue;
- move-result-object p1
- iput-object p1, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->queue:Lio/reactivex/internal/fuseable/SimpleQueue;
- :cond_2
- return-void
- .end method
- .method public queue()Lio/reactivex/internal/fuseable/SimpleQueue;
- .locals 1
- .annotation system Ldalvik/annotation/Signature;
- value = {
- "()",
- "Lio/reactivex/internal/fuseable/SimpleQueue<",
- "TT;>;"
- }
- .end annotation
- .line 116
- iget-object v0, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->queue:Lio/reactivex/internal/fuseable/SimpleQueue;
- return-object v0
- .end method
- .method public setDone()V
- .locals 1
- const/4 v0, 0x1
- .line 112
- iput-boolean v0, p0, Lio/reactivex/internal/observers/InnerQueuedObserver;->done:Z
- return-void
- .end method
|