PublishProcessor$PublishSubscription.smali 6.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260
  1. .class final Lio/reactivex/processors/PublishProcessor$PublishSubscription;
  2. .super Ljava/util/concurrent/atomic/AtomicLong;
  3. .source "PublishProcessor.java"
  4. # interfaces
  5. .implements Lorg/reactivestreams/Subscription;
  6. # annotations
  7. .annotation system Ldalvik/annotation/EnclosingClass;
  8. value = Lio/reactivex/processors/PublishProcessor;
  9. .end annotation
  10. .annotation system Ldalvik/annotation/InnerClass;
  11. accessFlags = 0x18
  12. name = "PublishSubscription"
  13. .end annotation
  14. .annotation system Ldalvik/annotation/Signature;
  15. value = {
  16. "<T:",
  17. "Ljava/lang/Object;",
  18. ">",
  19. "Ljava/util/concurrent/atomic/AtomicLong;",
  20. "Lorg/reactivestreams/Subscription;"
  21. }
  22. .end annotation
  23. # static fields
  24. .field private static final serialVersionUID:J = 0x3171d4005ebf93feL
  25. # instance fields
  26. .field final actual:Lorg/reactivestreams/Subscriber;
  27. .annotation system Ldalvik/annotation/Signature;
  28. value = {
  29. "Lorg/reactivestreams/Subscriber<",
  30. "-TT;>;"
  31. }
  32. .end annotation
  33. .end field
  34. .field final parent:Lio/reactivex/processors/PublishProcessor;
  35. .annotation system Ldalvik/annotation/Signature;
  36. value = {
  37. "Lio/reactivex/processors/PublishProcessor<",
  38. "TT;>;"
  39. }
  40. .end annotation
  41. .end field
  42. # direct methods
  43. .method constructor <init>(Lorg/reactivestreams/Subscriber;Lio/reactivex/processors/PublishProcessor;)V
  44. .locals 0
  45. .annotation system Ldalvik/annotation/Signature;
  46. value = {
  47. "(",
  48. "Lorg/reactivestreams/Subscriber<",
  49. "-TT;>;",
  50. "Lio/reactivex/processors/PublishProcessor<",
  51. "TT;>;)V"
  52. }
  53. .end annotation
  54. .line 272
  55. invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicLong;-><init>()V
  56. .line 273
  57. iput-object p1, p0, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->actual:Lorg/reactivestreams/Subscriber;
  58. .line 274
  59. iput-object p2, p0, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->parent:Lio/reactivex/processors/PublishProcessor;
  60. return-void
  61. .end method
  62. # virtual methods
  63. .method public cancel()V
  64. .locals 5
  65. const-wide/high16 v0, -0x8000000000000000L
  66. .line 316
  67. invoke-virtual {p0, v0, v1}, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->getAndSet(J)J
  68. move-result-wide v2
  69. cmp-long v4, v2, v0
  70. if-eqz v4, :cond_0
  71. .line 317
  72. iget-object v0, p0, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->parent:Lio/reactivex/processors/PublishProcessor;
  73. invoke-virtual {v0, p0}, Lio/reactivex/processors/PublishProcessor;->remove(Lio/reactivex/processors/PublishProcessor$PublishSubscription;)V
  74. :cond_0
  75. return-void
  76. .end method
  77. .method public isCancelled()Z
  78. .locals 5
  79. .line 322
  80. invoke-virtual {p0}, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->get()J
  81. move-result-wide v0
  82. const-wide/high16 v2, -0x8000000000000000L
  83. cmp-long v4, v0, v2
  84. if-nez v4, :cond_0
  85. const/4 v0, 0x1
  86. goto :goto_0
  87. :cond_0
  88. const/4 v0, 0x0
  89. :goto_0
  90. return v0
  91. .end method
  92. .method public onComplete()V
  93. .locals 5
  94. .line 302
  95. invoke-virtual {p0}, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->get()J
  96. move-result-wide v0
  97. const-wide/high16 v2, -0x8000000000000000L
  98. cmp-long v4, v0, v2
  99. if-eqz v4, :cond_0
  100. .line 303
  101. iget-object v0, p0, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->actual:Lorg/reactivestreams/Subscriber;
  102. invoke-interface {v0}, Lorg/reactivestreams/Subscriber;->onComplete()V
  103. :cond_0
  104. return-void
  105. .end method
  106. .method public onError(Ljava/lang/Throwable;)V
  107. .locals 5
  108. .line 294
  109. invoke-virtual {p0}, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->get()J
  110. move-result-wide v0
  111. const-wide/high16 v2, -0x8000000000000000L
  112. cmp-long v4, v0, v2
  113. if-eqz v4, :cond_0
  114. .line 295
  115. iget-object v0, p0, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->actual:Lorg/reactivestreams/Subscriber;
  116. invoke-interface {v0, p1}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
  117. goto :goto_0
  118. .line 297
  119. :cond_0
  120. invoke-static {p1}, Lio/reactivex/plugins/RxJavaPlugins;->onError(Ljava/lang/Throwable;)V
  121. :goto_0
  122. return-void
  123. .end method
  124. .method public onNext(Ljava/lang/Object;)V
  125. .locals 5
  126. .annotation system Ldalvik/annotation/Signature;
  127. value = {
  128. "(TT;)V"
  129. }
  130. .end annotation
  131. .line 278
  132. invoke-virtual {p0}, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->get()J
  133. move-result-wide v0
  134. const-wide/high16 v2, -0x8000000000000000L
  135. cmp-long v4, v0, v2
  136. if-nez v4, :cond_0
  137. return-void
  138. :cond_0
  139. const-wide/16 v2, 0x0
  140. cmp-long v4, v0, v2
  141. if-eqz v4, :cond_1
  142. .line 283
  143. iget-object v2, p0, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->actual:Lorg/reactivestreams/Subscriber;
  144. invoke-interface {v2, p1}, Lorg/reactivestreams/Subscriber;->onNext(Ljava/lang/Object;)V
  145. const-wide v2, 0x7fffffffffffffffL
  146. cmp-long p1, v0, v2
  147. if-eqz p1, :cond_2
  148. .line 285
  149. invoke-virtual {p0}, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->decrementAndGet()J
  150. goto :goto_0
  151. .line 288
  152. :cond_1
  153. invoke-virtual {p0}, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->cancel()V
  154. .line 289
  155. iget-object p1, p0, Lio/reactivex/processors/PublishProcessor$PublishSubscription;->actual:Lorg/reactivestreams/Subscriber;
  156. new-instance v0, Lio/reactivex/exceptions/MissingBackpressureException;
  157. const-string v1, "Could not emit value due to lack of requests"
  158. invoke-direct {v0, v1}, Lio/reactivex/exceptions/MissingBackpressureException;-><init>(Ljava/lang/String;)V
  159. invoke-interface {p1, v0}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
  160. :cond_2
  161. :goto_0
  162. return-void
  163. .end method
  164. .method public request(J)V
  165. .locals 1
  166. .line 309
  167. invoke-static {p1, p2}, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->validate(J)Z
  168. move-result v0
  169. if-eqz v0, :cond_0
  170. .line 310
  171. invoke-static {p0, p1, p2}, Lio/reactivex/internal/util/BackpressureHelper;->addCancel(Ljava/util/concurrent/atomic/AtomicLong;J)J
  172. :cond_0
  173. return-void
  174. .end method