123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192 |
- .class public final Lio/reactivex/internal/disposables/ArrayCompositeDisposable;
- .super Ljava/util/concurrent/atomic/AtomicReferenceArray;
- .source "ArrayCompositeDisposable.java"
- # interfaces
- .implements Lio/reactivex/disposables/Disposable;
- # annotations
- .annotation system Ldalvik/annotation/Signature;
- value = {
- "Ljava/util/concurrent/atomic/AtomicReferenceArray<",
- "Lio/reactivex/disposables/Disposable;",
- ">;",
- "Lio/reactivex/disposables/Disposable;"
- }
- .end annotation
- # static fields
- .field private static final serialVersionUID:J = 0x261d229f8c0b4b20L
- # direct methods
- .method public constructor <init>(I)V
- .locals 0
- .line 32
- invoke-direct {p0, p1}, Ljava/util/concurrent/atomic/AtomicReferenceArray;-><init>(I)V
- return-void
- .end method
- # virtual methods
- .method public dispose()V
- .locals 4
- const/4 v0, 0x0
- .line 78
- invoke-virtual {p0, v0}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->get(I)Ljava/lang/Object;
- move-result-object v1
- sget-object v2, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
- if-eq v1, v2, :cond_1
- .line 79
- invoke-virtual {p0}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->length()I
- move-result v1
- :goto_0
- if-ge v0, v1, :cond_1
- .line 81
- invoke-virtual {p0, v0}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->get(I)Ljava/lang/Object;
- move-result-object v2
- check-cast v2, Lio/reactivex/disposables/Disposable;
- .line 82
- sget-object v3, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
- if-eq v2, v3, :cond_0
- .line 83
- sget-object v2, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
- invoke-virtual {p0, v0, v2}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->getAndSet(ILjava/lang/Object;)Ljava/lang/Object;
- move-result-object v2
- check-cast v2, Lio/reactivex/disposables/Disposable;
- .line 84
- sget-object v3, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
- if-eq v2, v3, :cond_0
- if-eqz v2, :cond_0
- .line 85
- invoke-interface {v2}, Lio/reactivex/disposables/Disposable;->dispose()V
- :cond_0
- add-int/lit8 v0, v0, 0x1
- goto :goto_0
- :cond_1
- return-void
- .end method
- .method public isDisposed()Z
- .locals 3
- const/4 v0, 0x0
- .line 94
- invoke-virtual {p0, v0}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->get(I)Ljava/lang/Object;
- move-result-object v1
- sget-object v2, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
- if-ne v1, v2, :cond_0
- const/4 v0, 0x1
- :cond_0
- return v0
- .end method
- .method public replaceResource(ILio/reactivex/disposables/Disposable;)Lio/reactivex/disposables/Disposable;
- .locals 2
- .line 65
- :cond_0
- invoke-virtual {p0, p1}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->get(I)Ljava/lang/Object;
- move-result-object v0
- check-cast v0, Lio/reactivex/disposables/Disposable;
- .line 66
- sget-object v1, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
- if-ne v0, v1, :cond_1
- .line 67
- invoke-interface {p2}, Lio/reactivex/disposables/Disposable;->dispose()V
- const/4 p1, 0x0
- return-object p1
- .line 70
- :cond_1
- invoke-virtual {p0, p1, v0, p2}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->compareAndSet(ILjava/lang/Object;Ljava/lang/Object;)Z
- move-result v1
- if-eqz v1, :cond_0
- return-object v0
- .end method
- .method public setResource(ILio/reactivex/disposables/Disposable;)Z
- .locals 2
- .line 43
- :cond_0
- invoke-virtual {p0, p1}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->get(I)Ljava/lang/Object;
- move-result-object v0
- check-cast v0, Lio/reactivex/disposables/Disposable;
- .line 44
- sget-object v1, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
- if-ne v0, v1, :cond_1
- .line 45
- invoke-interface {p2}, Lio/reactivex/disposables/Disposable;->dispose()V
- const/4 p1, 0x0
- return p1
- .line 48
- :cond_1
- invoke-virtual {p0, p1, v0, p2}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->compareAndSet(ILjava/lang/Object;Ljava/lang/Object;)Z
- move-result v1
- if-eqz v1, :cond_0
- if-eqz v0, :cond_2
- .line 50
- invoke-interface {v0}, Lio/reactivex/disposables/Disposable;->dispose()V
- :cond_2
- const/4 p1, 0x1
- return p1
- .end method
|