NotificationLite.smali 13 KB

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