ArrayCompositeDisposable.smali 4.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192
  1. .class public final Lio/reactivex/internal/disposables/ArrayCompositeDisposable;
  2. .super Ljava/util/concurrent/atomic/AtomicReferenceArray;
  3. .source "ArrayCompositeDisposable.java"
  4. # interfaces
  5. .implements Lio/reactivex/disposables/Disposable;
  6. # annotations
  7. .annotation system Ldalvik/annotation/Signature;
  8. value = {
  9. "Ljava/util/concurrent/atomic/AtomicReferenceArray<",
  10. "Lio/reactivex/disposables/Disposable;",
  11. ">;",
  12. "Lio/reactivex/disposables/Disposable;"
  13. }
  14. .end annotation
  15. # static fields
  16. .field private static final serialVersionUID:J = 0x261d229f8c0b4b20L
  17. # direct methods
  18. .method public constructor <init>(I)V
  19. .locals 0
  20. .line 32
  21. invoke-direct {p0, p1}, Ljava/util/concurrent/atomic/AtomicReferenceArray;-><init>(I)V
  22. return-void
  23. .end method
  24. # virtual methods
  25. .method public dispose()V
  26. .locals 4
  27. const/4 v0, 0x0
  28. .line 78
  29. invoke-virtual {p0, v0}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->get(I)Ljava/lang/Object;
  30. move-result-object v1
  31. sget-object v2, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
  32. if-eq v1, v2, :cond_1
  33. .line 79
  34. invoke-virtual {p0}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->length()I
  35. move-result v1
  36. :goto_0
  37. if-ge v0, v1, :cond_1
  38. .line 81
  39. invoke-virtual {p0, v0}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->get(I)Ljava/lang/Object;
  40. move-result-object v2
  41. check-cast v2, Lio/reactivex/disposables/Disposable;
  42. .line 82
  43. sget-object v3, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
  44. if-eq v2, v3, :cond_0
  45. .line 83
  46. sget-object v2, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
  47. invoke-virtual {p0, v0, v2}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->getAndSet(ILjava/lang/Object;)Ljava/lang/Object;
  48. move-result-object v2
  49. check-cast v2, Lio/reactivex/disposables/Disposable;
  50. .line 84
  51. sget-object v3, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
  52. if-eq v2, v3, :cond_0
  53. if-eqz v2, :cond_0
  54. .line 85
  55. invoke-interface {v2}, Lio/reactivex/disposables/Disposable;->dispose()V
  56. :cond_0
  57. add-int/lit8 v0, v0, 0x1
  58. goto :goto_0
  59. :cond_1
  60. return-void
  61. .end method
  62. .method public isDisposed()Z
  63. .locals 3
  64. const/4 v0, 0x0
  65. .line 94
  66. invoke-virtual {p0, v0}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->get(I)Ljava/lang/Object;
  67. move-result-object v1
  68. sget-object v2, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
  69. if-ne v1, v2, :cond_0
  70. const/4 v0, 0x1
  71. :cond_0
  72. return v0
  73. .end method
  74. .method public replaceResource(ILio/reactivex/disposables/Disposable;)Lio/reactivex/disposables/Disposable;
  75. .locals 2
  76. .line 65
  77. :cond_0
  78. invoke-virtual {p0, p1}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->get(I)Ljava/lang/Object;
  79. move-result-object v0
  80. check-cast v0, Lio/reactivex/disposables/Disposable;
  81. .line 66
  82. sget-object v1, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
  83. if-ne v0, v1, :cond_1
  84. .line 67
  85. invoke-interface {p2}, Lio/reactivex/disposables/Disposable;->dispose()V
  86. const/4 p1, 0x0
  87. return-object p1
  88. .line 70
  89. :cond_1
  90. invoke-virtual {p0, p1, v0, p2}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->compareAndSet(ILjava/lang/Object;Ljava/lang/Object;)Z
  91. move-result v1
  92. if-eqz v1, :cond_0
  93. return-object v0
  94. .end method
  95. .method public setResource(ILio/reactivex/disposables/Disposable;)Z
  96. .locals 2
  97. .line 43
  98. :cond_0
  99. invoke-virtual {p0, p1}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->get(I)Ljava/lang/Object;
  100. move-result-object v0
  101. check-cast v0, Lio/reactivex/disposables/Disposable;
  102. .line 44
  103. sget-object v1, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper;
  104. if-ne v0, v1, :cond_1
  105. .line 45
  106. invoke-interface {p2}, Lio/reactivex/disposables/Disposable;->dispose()V
  107. const/4 p1, 0x0
  108. return p1
  109. .line 48
  110. :cond_1
  111. invoke-virtual {p0, p1, v0, p2}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->compareAndSet(ILjava/lang/Object;Ljava/lang/Object;)Z
  112. move-result v1
  113. if-eqz v1, :cond_0
  114. if-eqz v0, :cond_2
  115. .line 50
  116. invoke-interface {v0}, Lio/reactivex/disposables/Disposable;->dispose()V
  117. :cond_2
  118. const/4 p1, 0x1
  119. return p1
  120. .end method