FutureSubscriber.smali 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497
  1. .class public final Lio/reactivex/internal/subscribers/FutureSubscriber;
  2. .super Ljava/util/concurrent/CountDownLatch;
  3. .source "FutureSubscriber.java"
  4. # interfaces
  5. .implements Lorg/reactivestreams/Subscriber;
  6. .implements Ljava/util/concurrent/Future;
  7. .implements Lorg/reactivestreams/Subscription;
  8. # annotations
  9. .annotation system Ldalvik/annotation/Signature;
  10. value = {
  11. "<T:",
  12. "Ljava/lang/Object;",
  13. ">",
  14. "Ljava/util/concurrent/CountDownLatch;",
  15. "Lorg/reactivestreams/Subscriber<",
  16. "TT;>;",
  17. "Ljava/util/concurrent/Future<",
  18. "TT;>;",
  19. "Lorg/reactivestreams/Subscription;"
  20. }
  21. .end annotation
  22. # instance fields
  23. .field error:Ljava/lang/Throwable;
  24. .field final s:Ljava/util/concurrent/atomic/AtomicReference;
  25. .annotation system Ldalvik/annotation/Signature;
  26. value = {
  27. "Ljava/util/concurrent/atomic/AtomicReference<",
  28. "Lorg/reactivestreams/Subscription;",
  29. ">;"
  30. }
  31. .end annotation
  32. .end field
  33. .field value:Ljava/lang/Object;
  34. .annotation system Ldalvik/annotation/Signature;
  35. value = {
  36. "TT;"
  37. }
  38. .end annotation
  39. .end field
  40. # direct methods
  41. .method public constructor <init>()V
  42. .locals 1
  43. const/4 v0, 0x1
  44. .line 41
  45. invoke-direct {p0, v0}, Ljava/util/concurrent/CountDownLatch;-><init>(I)V
  46. .line 42
  47. new-instance v0, Ljava/util/concurrent/atomic/AtomicReference;
  48. invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
  49. iput-object v0, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->s:Ljava/util/concurrent/atomic/AtomicReference;
  50. return-void
  51. .end method
  52. # virtual methods
  53. .method public cancel()V
  54. .locals 0
  55. return-void
  56. .end method
  57. .method public cancel(Z)Z
  58. .locals 2
  59. .line 48
  60. :cond_0
  61. iget-object p1, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->s:Ljava/util/concurrent/atomic/AtomicReference;
  62. invoke-virtual {p1}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
  63. move-result-object p1
  64. check-cast p1, Lorg/reactivestreams/Subscription;
  65. if-eq p1, p0, :cond_3
  66. .line 49
  67. sget-object v0, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->CANCELLED:Lio/reactivex/internal/subscriptions/SubscriptionHelper;
  68. if-ne p1, v0, :cond_1
  69. goto :goto_0
  70. .line 53
  71. :cond_1
  72. iget-object v0, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->s:Ljava/util/concurrent/atomic/AtomicReference;
  73. sget-object v1, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->CANCELLED:Lio/reactivex/internal/subscriptions/SubscriptionHelper;
  74. invoke-virtual {v0, p1, v1}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z
  75. move-result v0
  76. if-eqz v0, :cond_0
  77. if-eqz p1, :cond_2
  78. .line 55
  79. invoke-interface {p1}, Lorg/reactivestreams/Subscription;->cancel()V
  80. .line 57
  81. :cond_2
  82. invoke-virtual {p0}, Lio/reactivex/internal/subscribers/FutureSubscriber;->countDown()V
  83. const/4 p1, 0x1
  84. return p1
  85. :cond_3
  86. :goto_0
  87. const/4 p1, 0x0
  88. return p1
  89. .end method
  90. .method public get()Ljava/lang/Object;
  91. .locals 5
  92. .annotation system Ldalvik/annotation/Signature;
  93. value = {
  94. "()TT;"
  95. }
  96. .end annotation
  97. .annotation system Ldalvik/annotation/Throws;
  98. value = {
  99. Ljava/lang/InterruptedException;,
  100. Ljava/util/concurrent/ExecutionException;
  101. }
  102. .end annotation
  103. .line 75
  104. invoke-virtual {p0}, Lio/reactivex/internal/subscribers/FutureSubscriber;->getCount()J
  105. move-result-wide v0
  106. const-wide/16 v2, 0x0
  107. cmp-long v4, v0, v2
  108. if-eqz v4, :cond_0
  109. .line 76
  110. invoke-static {}, Lio/reactivex/internal/util/BlockingHelper;->verifyNonBlocking()V
  111. .line 77
  112. invoke-virtual {p0}, Lio/reactivex/internal/subscribers/FutureSubscriber;->await()V
  113. .line 80
  114. :cond_0
  115. invoke-virtual {p0}, Lio/reactivex/internal/subscribers/FutureSubscriber;->isCancelled()Z
  116. move-result v0
  117. if-nez v0, :cond_2
  118. .line 83
  119. iget-object v0, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->error:Ljava/lang/Throwable;
  120. if-nez v0, :cond_1
  121. .line 87
  122. iget-object v0, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->value:Ljava/lang/Object;
  123. return-object v0
  124. .line 85
  125. :cond_1
  126. new-instance v1, Ljava/util/concurrent/ExecutionException;
  127. invoke-direct {v1, v0}, Ljava/util/concurrent/ExecutionException;-><init>(Ljava/lang/Throwable;)V
  128. throw v1
  129. .line 81
  130. :cond_2
  131. new-instance v0, Ljava/util/concurrent/CancellationException;
  132. invoke-direct {v0}, Ljava/util/concurrent/CancellationException;-><init>()V
  133. throw v0
  134. .end method
  135. .method public get(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;
  136. .locals 5
  137. .annotation system Ldalvik/annotation/Signature;
  138. value = {
  139. "(J",
  140. "Ljava/util/concurrent/TimeUnit;",
  141. ")TT;"
  142. }
  143. .end annotation
  144. .annotation system Ldalvik/annotation/Throws;
  145. value = {
  146. Ljava/lang/InterruptedException;,
  147. Ljava/util/concurrent/ExecutionException;,
  148. Ljava/util/concurrent/TimeoutException;
  149. }
  150. .end annotation
  151. .line 92
  152. invoke-virtual {p0}, Lio/reactivex/internal/subscribers/FutureSubscriber;->getCount()J
  153. move-result-wide v0
  154. const-wide/16 v2, 0x0
  155. cmp-long v4, v0, v2
  156. if-eqz v4, :cond_1
  157. .line 93
  158. invoke-static {}, Lio/reactivex/internal/util/BlockingHelper;->verifyNonBlocking()V
  159. .line 94
  160. invoke-virtual {p0, p1, p2, p3}, Lio/reactivex/internal/subscribers/FutureSubscriber;->await(JLjava/util/concurrent/TimeUnit;)Z
  161. move-result p1
  162. if-eqz p1, :cond_0
  163. goto :goto_0
  164. .line 95
  165. :cond_0
  166. new-instance p1, Ljava/util/concurrent/TimeoutException;
  167. invoke-direct {p1}, Ljava/util/concurrent/TimeoutException;-><init>()V
  168. throw p1
  169. .line 99
  170. :cond_1
  171. :goto_0
  172. invoke-virtual {p0}, Lio/reactivex/internal/subscribers/FutureSubscriber;->isCancelled()Z
  173. move-result p1
  174. if-nez p1, :cond_3
  175. .line 103
  176. iget-object p1, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->error:Ljava/lang/Throwable;
  177. if-nez p1, :cond_2
  178. .line 107
  179. iget-object p1, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->value:Ljava/lang/Object;
  180. return-object p1
  181. .line 105
  182. :cond_2
  183. new-instance p2, Ljava/util/concurrent/ExecutionException;
  184. invoke-direct {p2, p1}, Ljava/util/concurrent/ExecutionException;-><init>(Ljava/lang/Throwable;)V
  185. throw p2
  186. .line 100
  187. :cond_3
  188. new-instance p1, Ljava/util/concurrent/CancellationException;
  189. invoke-direct {p1}, Ljava/util/concurrent/CancellationException;-><init>()V
  190. throw p1
  191. .end method
  192. .method public isCancelled()Z
  193. .locals 1
  194. .line 65
  195. iget-object v0, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->s:Ljava/util/concurrent/atomic/AtomicReference;
  196. invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
  197. move-result-object v0
  198. check-cast v0, Lorg/reactivestreams/Subscription;
  199. invoke-static {v0}, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->isCancelled(Lorg/reactivestreams/Subscription;)Z
  200. move-result v0
  201. return v0
  202. .end method
  203. .method public isDone()Z
  204. .locals 5
  205. .line 70
  206. invoke-virtual {p0}, Lio/reactivex/internal/subscribers/FutureSubscriber;->getCount()J
  207. move-result-wide v0
  208. const-wide/16 v2, 0x0
  209. cmp-long v4, v0, v2
  210. if-nez v4, :cond_0
  211. const/4 v0, 0x1
  212. goto :goto_0
  213. :cond_0
  214. const/4 v0, 0x0
  215. :goto_0
  216. return v0
  217. .end method
  218. .method public onComplete()V
  219. .locals 2
  220. .line 145
  221. iget-object v0, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->value:Ljava/lang/Object;
  222. if-nez v0, :cond_0
  223. .line 146
  224. new-instance v0, Ljava/util/NoSuchElementException;
  225. const-string v1, "The source is empty"
  226. invoke-direct {v0, v1}, Ljava/util/NoSuchElementException;-><init>(Ljava/lang/String;)V
  227. invoke-virtual {p0, v0}, Lio/reactivex/internal/subscribers/FutureSubscriber;->onError(Ljava/lang/Throwable;)V
  228. return-void
  229. .line 150
  230. :cond_0
  231. iget-object v0, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->s:Ljava/util/concurrent/atomic/AtomicReference;
  232. invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
  233. move-result-object v0
  234. check-cast v0, Lorg/reactivestreams/Subscription;
  235. if-eq v0, p0, :cond_2
  236. .line 151
  237. sget-object v1, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->CANCELLED:Lio/reactivex/internal/subscriptions/SubscriptionHelper;
  238. if-ne v0, v1, :cond_1
  239. goto :goto_0
  240. .line 154
  241. :cond_1
  242. iget-object v1, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->s:Ljava/util/concurrent/atomic/AtomicReference;
  243. invoke-virtual {v1, v0, p0}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z
  244. move-result v0
  245. if-eqz v0, :cond_0
  246. .line 155
  247. invoke-virtual {p0}, Lio/reactivex/internal/subscribers/FutureSubscriber;->countDown()V
  248. :cond_2
  249. :goto_0
  250. return-void
  251. .end method
  252. .method public onError(Ljava/lang/Throwable;)V
  253. .locals 2
  254. .line 130
  255. :cond_0
  256. iget-object v0, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->s:Ljava/util/concurrent/atomic/AtomicReference;
  257. invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
  258. move-result-object v0
  259. check-cast v0, Lorg/reactivestreams/Subscription;
  260. if-eq v0, p0, :cond_2
  261. .line 131
  262. sget-object v1, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->CANCELLED:Lio/reactivex/internal/subscriptions/SubscriptionHelper;
  263. if-ne v0, v1, :cond_1
  264. goto :goto_0
  265. .line 135
  266. :cond_1
  267. iput-object p1, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->error:Ljava/lang/Throwable;
  268. .line 136
  269. iget-object v1, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->s:Ljava/util/concurrent/atomic/AtomicReference;
  270. invoke-virtual {v1, v0, p0}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z
  271. move-result v0
  272. if-eqz v0, :cond_0
  273. .line 137
  274. invoke-virtual {p0}, Lio/reactivex/internal/subscribers/FutureSubscriber;->countDown()V
  275. return-void
  276. .line 132
  277. :cond_2
  278. :goto_0
  279. invoke-static {p1}, Lio/reactivex/plugins/RxJavaPlugins;->onError(Ljava/lang/Throwable;)V
  280. return-void
  281. .end method
  282. .method public onNext(Ljava/lang/Object;)V
  283. .locals 1
  284. .annotation system Ldalvik/annotation/Signature;
  285. value = {
  286. "(TT;)V"
  287. }
  288. .end annotation
  289. .line 119
  290. iget-object v0, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->value:Ljava/lang/Object;
  291. if-eqz v0, :cond_0
  292. .line 120
  293. iget-object p1, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->s:Ljava/util/concurrent/atomic/AtomicReference;
  294. invoke-virtual {p1}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
  295. move-result-object p1
  296. check-cast p1, Lorg/reactivestreams/Subscription;
  297. invoke-interface {p1}, Lorg/reactivestreams/Subscription;->cancel()V
  298. .line 121
  299. new-instance p1, Ljava/lang/IndexOutOfBoundsException;
  300. const-string v0, "More than one element received"
  301. invoke-direct {p1, v0}, Ljava/lang/IndexOutOfBoundsException;-><init>(Ljava/lang/String;)V
  302. invoke-virtual {p0, p1}, Lio/reactivex/internal/subscribers/FutureSubscriber;->onError(Ljava/lang/Throwable;)V
  303. return-void
  304. .line 124
  305. :cond_0
  306. iput-object p1, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->value:Ljava/lang/Object;
  307. return-void
  308. .end method
  309. .method public onSubscribe(Lorg/reactivestreams/Subscription;)V
  310. .locals 2
  311. .line 112
  312. iget-object v0, p0, Lio/reactivex/internal/subscribers/FutureSubscriber;->s:Ljava/util/concurrent/atomic/AtomicReference;
  313. invoke-static {v0, p1}, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->setOnce(Ljava/util/concurrent/atomic/AtomicReference;Lorg/reactivestreams/Subscription;)Z
  314. move-result v0
  315. if-eqz v0, :cond_0
  316. const-wide v0, 0x7fffffffffffffffL
  317. .line 113
  318. invoke-interface {p1, v0, v1}, Lorg/reactivestreams/Subscription;->request(J)V
  319. :cond_0
  320. return-void
  321. .end method
  322. .method public request(J)V
  323. .locals 0
  324. return-void
  325. .end method