Functions.smali 33 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088
  1. .class public final Lio/reactivex/internal/functions/Functions;
  2. .super Ljava/lang/Object;
  3. .source "Functions.java"
  4. # annotations
  5. .annotation system Ldalvik/annotation/MemberClasses;
  6. value = {
  7. Lio/reactivex/internal/functions/Functions$ListSorter;,
  8. Lio/reactivex/internal/functions/Functions$NaturalComparator;,
  9. Lio/reactivex/internal/functions/Functions$ToMultimapKeyValueSelector;,
  10. Lio/reactivex/internal/functions/Functions$ToMapKeyValueSelector;,
  11. Lio/reactivex/internal/functions/Functions$ToMapKeySelector;,
  12. Lio/reactivex/internal/functions/Functions$TimestampFunction;,
  13. Lio/reactivex/internal/functions/Functions$BooleanSupplierPredicateReverse;,
  14. Lio/reactivex/internal/functions/Functions$ClassFilter;,
  15. Lio/reactivex/internal/functions/Functions$ActionConsumer;,
  16. Lio/reactivex/internal/functions/Functions$NotificationOnComplete;,
  17. Lio/reactivex/internal/functions/Functions$NotificationOnError;,
  18. Lio/reactivex/internal/functions/Functions$NotificationOnNext;,
  19. Lio/reactivex/internal/functions/Functions$HashSetCallable;,
  20. Lio/reactivex/internal/functions/Functions$EqualsPredicate;,
  21. Lio/reactivex/internal/functions/Functions$ArrayListCapacityCallable;,
  22. Lio/reactivex/internal/functions/Functions$CastToClass;,
  23. Lio/reactivex/internal/functions/Functions$JustValue;,
  24. Lio/reactivex/internal/functions/Functions$FutureAction;
  25. }
  26. .end annotation
  27. # static fields
  28. .field static final ALWAYS_FALSE:Lio/reactivex/functions/Predicate;
  29. .annotation system Ldalvik/annotation/Signature;
  30. value = {
  31. "Lio/reactivex/functions/Predicate<",
  32. "Ljava/lang/Object;",
  33. ">;"
  34. }
  35. .end annotation
  36. .end field
  37. .field static final ALWAYS_TRUE:Lio/reactivex/functions/Predicate;
  38. .annotation system Ldalvik/annotation/Signature;
  39. value = {
  40. "Lio/reactivex/functions/Predicate<",
  41. "Ljava/lang/Object;",
  42. ">;"
  43. }
  44. .end annotation
  45. .end field
  46. .field public static final EMPTY_ACTION:Lio/reactivex/functions/Action;
  47. .field static final EMPTY_CONSUMER:Lio/reactivex/functions/Consumer;
  48. .annotation system Ldalvik/annotation/Signature;
  49. value = {
  50. "Lio/reactivex/functions/Consumer<",
  51. "Ljava/lang/Object;",
  52. ">;"
  53. }
  54. .end annotation
  55. .end field
  56. .field public static final EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
  57. .field public static final EMPTY_RUNNABLE:Ljava/lang/Runnable;
  58. .field public static final ERROR_CONSUMER:Lio/reactivex/functions/Consumer;
  59. .annotation system Ldalvik/annotation/Signature;
  60. value = {
  61. "Lio/reactivex/functions/Consumer<",
  62. "Ljava/lang/Throwable;",
  63. ">;"
  64. }
  65. .end annotation
  66. .end field
  67. .field static final IDENTITY:Lio/reactivex/functions/Function;
  68. .annotation system Ldalvik/annotation/Signature;
  69. value = {
  70. "Lio/reactivex/functions/Function<",
  71. "Ljava/lang/Object;",
  72. "Ljava/lang/Object;",
  73. ">;"
  74. }
  75. .end annotation
  76. .end field
  77. .field static final NATURAL_COMPARATOR:Ljava/util/Comparator;
  78. .annotation system Ldalvik/annotation/Signature;
  79. value = {
  80. "Ljava/util/Comparator<",
  81. "Ljava/lang/Object;",
  82. ">;"
  83. }
  84. .end annotation
  85. .end field
  86. .field static final NULL_SUPPLIER:Ljava/util/concurrent/Callable;
  87. .annotation system Ldalvik/annotation/Signature;
  88. value = {
  89. "Ljava/util/concurrent/Callable<",
  90. "Ljava/lang/Object;",
  91. ">;"
  92. }
  93. .end annotation
  94. .end field
  95. .field public static final REQUEST_MAX:Lio/reactivex/functions/Consumer;
  96. .annotation system Ldalvik/annotation/Signature;
  97. value = {
  98. "Lio/reactivex/functions/Consumer<",
  99. "Lorg/reactivestreams/Subscription;",
  100. ">;"
  101. }
  102. .end annotation
  103. .end field
  104. # direct methods
  105. .method static constructor <clinit>()V
  106. .locals 1
  107. .line 152
  108. new-instance v0, Lio/reactivex/internal/functions/Functions$9;
  109. invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$9;-><init>()V
  110. sput-object v0, Lio/reactivex/internal/functions/Functions;->IDENTITY:Lio/reactivex/functions/Function;
  111. .line 174
  112. new-instance v0, Lio/reactivex/internal/functions/Functions$10;
  113. invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$10;-><init>()V
  114. sput-object v0, Lio/reactivex/internal/functions/Functions;->EMPTY_RUNNABLE:Ljava/lang/Runnable;
  115. .line 184
  116. new-instance v0, Lio/reactivex/internal/functions/Functions$11;
  117. invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$11;-><init>()V
  118. sput-object v0, Lio/reactivex/internal/functions/Functions;->EMPTY_ACTION:Lio/reactivex/functions/Action;
  119. .line 194
  120. new-instance v0, Lio/reactivex/internal/functions/Functions$12;
  121. invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$12;-><init>()V
  122. sput-object v0, Lio/reactivex/internal/functions/Functions;->EMPTY_CONSUMER:Lio/reactivex/functions/Consumer;
  123. .line 214
  124. new-instance v0, Lio/reactivex/internal/functions/Functions$13;
  125. invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$13;-><init>()V
  126. sput-object v0, Lio/reactivex/internal/functions/Functions;->ERROR_CONSUMER:Lio/reactivex/functions/Consumer;
  127. .line 221
  128. new-instance v0, Lio/reactivex/internal/functions/Functions$14;
  129. invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$14;-><init>()V
  130. sput-object v0, Lio/reactivex/internal/functions/Functions;->EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
  131. .line 226
  132. new-instance v0, Lio/reactivex/internal/functions/Functions$15;
  133. invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$15;-><init>()V
  134. sput-object v0, Lio/reactivex/internal/functions/Functions;->ALWAYS_TRUE:Lio/reactivex/functions/Predicate;
  135. .line 233
  136. new-instance v0, Lio/reactivex/internal/functions/Functions$16;
  137. invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$16;-><init>()V
  138. sput-object v0, Lio/reactivex/internal/functions/Functions;->ALWAYS_FALSE:Lio/reactivex/functions/Predicate;
  139. .line 240
  140. new-instance v0, Lio/reactivex/internal/functions/Functions$17;
  141. invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$17;-><init>()V
  142. sput-object v0, Lio/reactivex/internal/functions/Functions;->NULL_SUPPLIER:Ljava/util/concurrent/Callable;
  143. .line 247
  144. new-instance v0, Lio/reactivex/internal/functions/Functions$18;
  145. invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$18;-><init>()V
  146. sput-object v0, Lio/reactivex/internal/functions/Functions;->NATURAL_COMPARATOR:Ljava/util/Comparator;
  147. .line 642
  148. new-instance v0, Lio/reactivex/internal/functions/Functions$19;
  149. invoke-direct {v0}, Lio/reactivex/internal/functions/Functions$19;-><init>()V
  150. sput-object v0, Lio/reactivex/internal/functions/Functions;->REQUEST_MAX:Lio/reactivex/functions/Consumer;
  151. return-void
  152. .end method
  153. .method private constructor <init>()V
  154. .locals 2
  155. .line 31
  156. invoke-direct {p0}, Ljava/lang/Object;-><init>()V
  157. .line 32
  158. new-instance v0, Ljava/lang/IllegalStateException;
  159. const-string v1, "No instances!"
  160. invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
  161. throw v0
  162. .end method
  163. .method public static actionConsumer(Lio/reactivex/functions/Action;)Lio/reactivex/functions/Consumer;
  164. .locals 1
  165. .annotation system Ldalvik/annotation/Signature;
  166. value = {
  167. "<T:",
  168. "Ljava/lang/Object;",
  169. ">(",
  170. "Lio/reactivex/functions/Action;",
  171. ")",
  172. "Lio/reactivex/functions/Consumer<",
  173. "TT;>;"
  174. }
  175. .end annotation
  176. .line 477
  177. new-instance v0, Lio/reactivex/internal/functions/Functions$ActionConsumer;
  178. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$ActionConsumer;-><init>(Lio/reactivex/functions/Action;)V
  179. return-object v0
  180. .end method
  181. .method public static alwaysFalse()Lio/reactivex/functions/Predicate;
  182. .locals 1
  183. .annotation system Ldalvik/annotation/Signature;
  184. value = {
  185. "<T:",
  186. "Ljava/lang/Object;",
  187. ">()",
  188. "Lio/reactivex/functions/Predicate<",
  189. "TT;>;"
  190. }
  191. .end annotation
  192. .line 262
  193. sget-object v0, Lio/reactivex/internal/functions/Functions;->ALWAYS_FALSE:Lio/reactivex/functions/Predicate;
  194. return-object v0
  195. .end method
  196. .method public static alwaysTrue()Lio/reactivex/functions/Predicate;
  197. .locals 1
  198. .annotation system Ldalvik/annotation/Signature;
  199. value = {
  200. "<T:",
  201. "Ljava/lang/Object;",
  202. ">()",
  203. "Lio/reactivex/functions/Predicate<",
  204. "TT;>;"
  205. }
  206. .end annotation
  207. .line 257
  208. sget-object v0, Lio/reactivex/internal/functions/Functions;->ALWAYS_TRUE:Lio/reactivex/functions/Predicate;
  209. return-object v0
  210. .end method
  211. .method public static castFunction(Ljava/lang/Class;)Lio/reactivex/functions/Function;
  212. .locals 1
  213. .annotation system Ldalvik/annotation/Signature;
  214. value = {
  215. "<T:",
  216. "Ljava/lang/Object;",
  217. "U:",
  218. "Ljava/lang/Object;",
  219. ">(",
  220. "Ljava/lang/Class<",
  221. "TU;>;)",
  222. "Lio/reactivex/functions/Function<",
  223. "TT;TU;>;"
  224. }
  225. .end annotation
  226. .line 362
  227. new-instance v0, Lio/reactivex/internal/functions/Functions$CastToClass;
  228. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$CastToClass;-><init>(Ljava/lang/Class;)V
  229. return-object v0
  230. .end method
  231. .method public static createArrayList(I)Ljava/util/concurrent/Callable;
  232. .locals 1
  233. .annotation system Ldalvik/annotation/Signature;
  234. value = {
  235. "<T:",
  236. "Ljava/lang/Object;",
  237. ">(I)",
  238. "Ljava/util/concurrent/Callable<",
  239. "Ljava/util/List<",
  240. "TT;>;>;"
  241. }
  242. .end annotation
  243. .line 379
  244. new-instance v0, Lio/reactivex/internal/functions/Functions$ArrayListCapacityCallable;
  245. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$ArrayListCapacityCallable;-><init>(I)V
  246. return-object v0
  247. .end method
  248. .method public static createHashSet()Ljava/util/concurrent/Callable;
  249. .locals 1
  250. .annotation system Ldalvik/annotation/Signature;
  251. value = {
  252. "<T:",
  253. "Ljava/lang/Object;",
  254. ">()",
  255. "Ljava/util/concurrent/Callable<",
  256. "Ljava/util/Set<",
  257. "TT;>;>;"
  258. }
  259. .end annotation
  260. .line 409
  261. sget-object v0, Lio/reactivex/internal/functions/Functions$HashSetCallable;->INSTANCE:Lio/reactivex/internal/functions/Functions$HashSetCallable;
  262. return-object v0
  263. .end method
  264. .method public static emptyConsumer()Lio/reactivex/functions/Consumer;
  265. .locals 1
  266. .annotation system Ldalvik/annotation/Signature;
  267. value = {
  268. "<T:",
  269. "Ljava/lang/Object;",
  270. ">()",
  271. "Lio/reactivex/functions/Consumer<",
  272. "TT;>;"
  273. }
  274. .end annotation
  275. .line 211
  276. sget-object v0, Lio/reactivex/internal/functions/Functions;->EMPTY_CONSUMER:Lio/reactivex/functions/Consumer;
  277. return-object v0
  278. .end method
  279. .method public static equalsWith(Ljava/lang/Object;)Lio/reactivex/functions/Predicate;
  280. .locals 1
  281. .annotation system Ldalvik/annotation/Signature;
  282. value = {
  283. "<T:",
  284. "Ljava/lang/Object;",
  285. ">(TT;)",
  286. "Lio/reactivex/functions/Predicate<",
  287. "TT;>;"
  288. }
  289. .end annotation
  290. .line 396
  291. new-instance v0, Lio/reactivex/internal/functions/Functions$EqualsPredicate;
  292. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$EqualsPredicate;-><init>(Ljava/lang/Object;)V
  293. return-object v0
  294. .end method
  295. .method public static futureAction(Ljava/util/concurrent/Future;)Lio/reactivex/functions/Action;
  296. .locals 1
  297. .annotation system Ldalvik/annotation/Signature;
  298. value = {
  299. "(",
  300. "Ljava/util/concurrent/Future<",
  301. "*>;)",
  302. "Lio/reactivex/functions/Action;"
  303. }
  304. .end annotation
  305. .line 299
  306. new-instance v0, Lio/reactivex/internal/functions/Functions$FutureAction;
  307. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$FutureAction;-><init>(Ljava/util/concurrent/Future;)V
  308. return-object v0
  309. .end method
  310. .method public static identity()Lio/reactivex/functions/Function;
  311. .locals 1
  312. .annotation system Ldalvik/annotation/Signature;
  313. value = {
  314. "<T:",
  315. "Ljava/lang/Object;",
  316. ">()",
  317. "Lio/reactivex/functions/Function<",
  318. "TT;TT;>;"
  319. }
  320. .end annotation
  321. .line 171
  322. sget-object v0, Lio/reactivex/internal/functions/Functions;->IDENTITY:Lio/reactivex/functions/Function;
  323. return-object v0
  324. .end method
  325. .method public static isInstanceOf(Ljava/lang/Class;)Lio/reactivex/functions/Predicate;
  326. .locals 1
  327. .annotation system Ldalvik/annotation/Signature;
  328. value = {
  329. "<T:",
  330. "Ljava/lang/Object;",
  331. "U:",
  332. "Ljava/lang/Object;",
  333. ">(",
  334. "Ljava/lang/Class<",
  335. "TU;>;)",
  336. "Lio/reactivex/functions/Predicate<",
  337. "TT;>;"
  338. }
  339. .end annotation
  340. .line 494
  341. new-instance v0, Lio/reactivex/internal/functions/Functions$ClassFilter;
  342. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$ClassFilter;-><init>(Ljava/lang/Class;)V
  343. return-object v0
  344. .end method
  345. .method public static justCallable(Ljava/lang/Object;)Ljava/util/concurrent/Callable;
  346. .locals 1
  347. .annotation system Ldalvik/annotation/Signature;
  348. value = {
  349. "<T:",
  350. "Ljava/lang/Object;",
  351. ">(TT;)",
  352. "Ljava/util/concurrent/Callable<",
  353. "TT;>;"
  354. }
  355. .end annotation
  356. .line 327
  357. new-instance v0, Lio/reactivex/internal/functions/Functions$JustValue;
  358. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$JustValue;-><init>(Ljava/lang/Object;)V
  359. return-object v0
  360. .end method
  361. .method public static justFunction(Ljava/lang/Object;)Lio/reactivex/functions/Function;
  362. .locals 1
  363. .annotation system Ldalvik/annotation/Signature;
  364. value = {
  365. "<T:",
  366. "Ljava/lang/Object;",
  367. "U:",
  368. "Ljava/lang/Object;",
  369. ">(TU;)",
  370. "Lio/reactivex/functions/Function<",
  371. "TT;TU;>;"
  372. }
  373. .end annotation
  374. .line 338
  375. new-instance v0, Lio/reactivex/internal/functions/Functions$JustValue;
  376. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$JustValue;-><init>(Ljava/lang/Object;)V
  377. return-object v0
  378. .end method
  379. .method public static listSorter(Ljava/util/Comparator;)Lio/reactivex/functions/Function;
  380. .locals 1
  381. .annotation system Ldalvik/annotation/Signature;
  382. value = {
  383. "<T:",
  384. "Ljava/lang/Object;",
  385. ">(",
  386. "Ljava/util/Comparator<",
  387. "-TT;>;)",
  388. "Lio/reactivex/functions/Function<",
  389. "Ljava/util/List<",
  390. "TT;>;",
  391. "Ljava/util/List<",
  392. "TT;>;>;"
  393. }
  394. .end annotation
  395. .line 639
  396. new-instance v0, Lio/reactivex/internal/functions/Functions$ListSorter;
  397. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$ListSorter;-><init>(Ljava/util/Comparator;)V
  398. return-object v0
  399. .end method
  400. .method public static naturalComparator()Ljava/util/Comparator;
  401. .locals 1
  402. .annotation system Ldalvik/annotation/Signature;
  403. value = {
  404. "<T:",
  405. "Ljava/lang/Object;",
  406. ">()",
  407. "Ljava/util/Comparator<",
  408. "TT;>;"
  409. }
  410. .end annotation
  411. .line 621
  412. sget-object v0, Lio/reactivex/internal/functions/Functions$NaturalComparator;->INSTANCE:Lio/reactivex/internal/functions/Functions$NaturalComparator;
  413. return-object v0
  414. .end method
  415. .method public static naturalOrder()Ljava/util/Comparator;
  416. .locals 1
  417. .annotation system Ldalvik/annotation/Signature;
  418. value = {
  419. "<T:",
  420. "Ljava/lang/Object;",
  421. ">()",
  422. "Ljava/util/Comparator<",
  423. "TT;>;"
  424. }
  425. .end annotation
  426. .line 277
  427. sget-object v0, Lio/reactivex/internal/functions/Functions;->NATURAL_COMPARATOR:Ljava/util/Comparator;
  428. return-object v0
  429. .end method
  430. .method public static notificationOnComplete(Lio/reactivex/functions/Consumer;)Lio/reactivex/functions/Action;
  431. .locals 1
  432. .annotation system Ldalvik/annotation/Signature;
  433. value = {
  434. "<T:",
  435. "Ljava/lang/Object;",
  436. ">(",
  437. "Lio/reactivex/functions/Consumer<",
  438. "-",
  439. "Lio/reactivex/Notification<",
  440. "TT;>;>;)",
  441. "Lio/reactivex/functions/Action;"
  442. }
  443. .end annotation
  444. .line 460
  445. new-instance v0, Lio/reactivex/internal/functions/Functions$NotificationOnComplete;
  446. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$NotificationOnComplete;-><init>(Lio/reactivex/functions/Consumer;)V
  447. return-object v0
  448. .end method
  449. .method public static notificationOnError(Lio/reactivex/functions/Consumer;)Lio/reactivex/functions/Consumer;
  450. .locals 1
  451. .annotation system Ldalvik/annotation/Signature;
  452. value = {
  453. "<T:",
  454. "Ljava/lang/Object;",
  455. ">(",
  456. "Lio/reactivex/functions/Consumer<",
  457. "-",
  458. "Lio/reactivex/Notification<",
  459. "TT;>;>;)",
  460. "Lio/reactivex/functions/Consumer<",
  461. "Ljava/lang/Throwable;",
  462. ">;"
  463. }
  464. .end annotation
  465. .line 456
  466. new-instance v0, Lio/reactivex/internal/functions/Functions$NotificationOnError;
  467. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$NotificationOnError;-><init>(Lio/reactivex/functions/Consumer;)V
  468. return-object v0
  469. .end method
  470. .method public static notificationOnNext(Lio/reactivex/functions/Consumer;)Lio/reactivex/functions/Consumer;
  471. .locals 1
  472. .annotation system Ldalvik/annotation/Signature;
  473. value = {
  474. "<T:",
  475. "Ljava/lang/Object;",
  476. ">(",
  477. "Lio/reactivex/functions/Consumer<",
  478. "-",
  479. "Lio/reactivex/Notification<",
  480. "TT;>;>;)",
  481. "Lio/reactivex/functions/Consumer<",
  482. "TT;>;"
  483. }
  484. .end annotation
  485. .line 452
  486. new-instance v0, Lio/reactivex/internal/functions/Functions$NotificationOnNext;
  487. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$NotificationOnNext;-><init>(Lio/reactivex/functions/Consumer;)V
  488. return-object v0
  489. .end method
  490. .method public static nullSupplier()Ljava/util/concurrent/Callable;
  491. .locals 1
  492. .annotation system Ldalvik/annotation/Signature;
  493. value = {
  494. "<T:",
  495. "Ljava/lang/Object;",
  496. ">()",
  497. "Ljava/util/concurrent/Callable<",
  498. "TT;>;"
  499. }
  500. .end annotation
  501. .line 267
  502. sget-object v0, Lio/reactivex/internal/functions/Functions;->NULL_SUPPLIER:Ljava/util/concurrent/Callable;
  503. return-object v0
  504. .end method
  505. .method public static predicateReverseFor(Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/functions/Predicate;
  506. .locals 1
  507. .annotation system Ldalvik/annotation/Signature;
  508. value = {
  509. "<T:",
  510. "Ljava/lang/Object;",
  511. ">(",
  512. "Lio/reactivex/functions/BooleanSupplier;",
  513. ")",
  514. "Lio/reactivex/functions/Predicate<",
  515. "TT;>;"
  516. }
  517. .end annotation
  518. .line 511
  519. new-instance v0, Lio/reactivex/internal/functions/Functions$BooleanSupplierPredicateReverse;
  520. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$BooleanSupplierPredicateReverse;-><init>(Lio/reactivex/functions/BooleanSupplier;)V
  521. return-object v0
  522. .end method
  523. .method public static timestampWith(Ljava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/functions/Function;
  524. .locals 1
  525. .annotation system Ldalvik/annotation/Signature;
  526. value = {
  527. "<T:",
  528. "Ljava/lang/Object;",
  529. ">(",
  530. "Ljava/util/concurrent/TimeUnit;",
  531. "Lio/reactivex/Scheduler;",
  532. ")",
  533. "Lio/reactivex/functions/Function<",
  534. "TT;",
  535. "Lio/reactivex/schedulers/Timed<",
  536. "TT;>;>;"
  537. }
  538. .end annotation
  539. .line 531
  540. new-instance v0, Lio/reactivex/internal/functions/Functions$TimestampFunction;
  541. invoke-direct {v0, p0, p1}, Lio/reactivex/internal/functions/Functions$TimestampFunction;-><init>(Ljava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)V
  542. return-object v0
  543. .end method
  544. .method public static toFunction(Lio/reactivex/functions/BiFunction;)Lio/reactivex/functions/Function;
  545. .locals 1
  546. .annotation system Ldalvik/annotation/Signature;
  547. value = {
  548. "<T1:",
  549. "Ljava/lang/Object;",
  550. "T2:",
  551. "Ljava/lang/Object;",
  552. "R:",
  553. "Ljava/lang/Object;",
  554. ">(",
  555. "Lio/reactivex/functions/BiFunction<",
  556. "-TT1;-TT2;+TR;>;)",
  557. "Lio/reactivex/functions/Function<",
  558. "[",
  559. "Ljava/lang/Object;",
  560. "TR;>;"
  561. }
  562. .end annotation
  563. const-string v0, "f is null"
  564. .line 37
  565. invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
  566. .line 38
  567. new-instance v0, Lio/reactivex/internal/functions/Functions$1;
  568. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$1;-><init>(Lio/reactivex/functions/BiFunction;)V
  569. return-object v0
  570. .end method
  571. .method public static toFunction(Lio/reactivex/functions/Function3;)Lio/reactivex/functions/Function;
  572. .locals 1
  573. .annotation system Ldalvik/annotation/Signature;
  574. value = {
  575. "<T1:",
  576. "Ljava/lang/Object;",
  577. "T2:",
  578. "Ljava/lang/Object;",
  579. "T3:",
  580. "Ljava/lang/Object;",
  581. "R:",
  582. "Ljava/lang/Object;",
  583. ">(",
  584. "Lio/reactivex/functions/Function3<",
  585. "TT1;TT2;TT3;TR;>;)",
  586. "Lio/reactivex/functions/Function<",
  587. "[",
  588. "Ljava/lang/Object;",
  589. "TR;>;"
  590. }
  591. .end annotation
  592. const-string v0, "f is null"
  593. .line 50
  594. invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
  595. .line 51
  596. new-instance v0, Lio/reactivex/internal/functions/Functions$2;
  597. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$2;-><init>(Lio/reactivex/functions/Function3;)V
  598. return-object v0
  599. .end method
  600. .method public static toFunction(Lio/reactivex/functions/Function4;)Lio/reactivex/functions/Function;
  601. .locals 1
  602. .annotation system Ldalvik/annotation/Signature;
  603. value = {
  604. "<T1:",
  605. "Ljava/lang/Object;",
  606. "T2:",
  607. "Ljava/lang/Object;",
  608. "T3:",
  609. "Ljava/lang/Object;",
  610. "T4:",
  611. "Ljava/lang/Object;",
  612. "R:",
  613. "Ljava/lang/Object;",
  614. ">(",
  615. "Lio/reactivex/functions/Function4<",
  616. "TT1;TT2;TT3;TT4;TR;>;)",
  617. "Lio/reactivex/functions/Function<",
  618. "[",
  619. "Ljava/lang/Object;",
  620. "TR;>;"
  621. }
  622. .end annotation
  623. const-string v0, "f is null"
  624. .line 64
  625. invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
  626. .line 65
  627. new-instance v0, Lio/reactivex/internal/functions/Functions$3;
  628. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$3;-><init>(Lio/reactivex/functions/Function4;)V
  629. return-object v0
  630. .end method
  631. .method public static toFunction(Lio/reactivex/functions/Function5;)Lio/reactivex/functions/Function;
  632. .locals 1
  633. .annotation system Ldalvik/annotation/Signature;
  634. value = {
  635. "<T1:",
  636. "Ljava/lang/Object;",
  637. "T2:",
  638. "Ljava/lang/Object;",
  639. "T3:",
  640. "Ljava/lang/Object;",
  641. "T4:",
  642. "Ljava/lang/Object;",
  643. "T5:",
  644. "Ljava/lang/Object;",
  645. "R:",
  646. "Ljava/lang/Object;",
  647. ">(",
  648. "Lio/reactivex/functions/Function5<",
  649. "TT1;TT2;TT3;TT4;TT5;TR;>;)",
  650. "Lio/reactivex/functions/Function<",
  651. "[",
  652. "Ljava/lang/Object;",
  653. "TR;>;"
  654. }
  655. .end annotation
  656. const-string v0, "f is null"
  657. .line 78
  658. invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
  659. .line 79
  660. new-instance v0, Lio/reactivex/internal/functions/Functions$4;
  661. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$4;-><init>(Lio/reactivex/functions/Function5;)V
  662. return-object v0
  663. .end method
  664. .method public static toFunction(Lio/reactivex/functions/Function6;)Lio/reactivex/functions/Function;
  665. .locals 1
  666. .annotation system Ldalvik/annotation/Signature;
  667. value = {
  668. "<T1:",
  669. "Ljava/lang/Object;",
  670. "T2:",
  671. "Ljava/lang/Object;",
  672. "T3:",
  673. "Ljava/lang/Object;",
  674. "T4:",
  675. "Ljava/lang/Object;",
  676. "T5:",
  677. "Ljava/lang/Object;",
  678. "T6:",
  679. "Ljava/lang/Object;",
  680. "R:",
  681. "Ljava/lang/Object;",
  682. ">(",
  683. "Lio/reactivex/functions/Function6<",
  684. "TT1;TT2;TT3;TT4;TT5;TT6;TR;>;)",
  685. "Lio/reactivex/functions/Function<",
  686. "[",
  687. "Ljava/lang/Object;",
  688. "TR;>;"
  689. }
  690. .end annotation
  691. const-string v0, "f is null"
  692. .line 93
  693. invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
  694. .line 94
  695. new-instance v0, Lio/reactivex/internal/functions/Functions$5;
  696. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$5;-><init>(Lio/reactivex/functions/Function6;)V
  697. return-object v0
  698. .end method
  699. .method public static toFunction(Lio/reactivex/functions/Function7;)Lio/reactivex/functions/Function;
  700. .locals 1
  701. .annotation system Ldalvik/annotation/Signature;
  702. value = {
  703. "<T1:",
  704. "Ljava/lang/Object;",
  705. "T2:",
  706. "Ljava/lang/Object;",
  707. "T3:",
  708. "Ljava/lang/Object;",
  709. "T4:",
  710. "Ljava/lang/Object;",
  711. "T5:",
  712. "Ljava/lang/Object;",
  713. "T6:",
  714. "Ljava/lang/Object;",
  715. "T7:",
  716. "Ljava/lang/Object;",
  717. "R:",
  718. "Ljava/lang/Object;",
  719. ">(",
  720. "Lio/reactivex/functions/Function7<",
  721. "TT1;TT2;TT3;TT4;TT5;TT6;TT7;TR;>;)",
  722. "Lio/reactivex/functions/Function<",
  723. "[",
  724. "Ljava/lang/Object;",
  725. "TR;>;"
  726. }
  727. .end annotation
  728. const-string v0, "f is null"
  729. .line 108
  730. invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
  731. .line 109
  732. new-instance v0, Lio/reactivex/internal/functions/Functions$6;
  733. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$6;-><init>(Lio/reactivex/functions/Function7;)V
  734. return-object v0
  735. .end method
  736. .method public static toFunction(Lio/reactivex/functions/Function8;)Lio/reactivex/functions/Function;
  737. .locals 1
  738. .annotation system Ldalvik/annotation/Signature;
  739. value = {
  740. "<T1:",
  741. "Ljava/lang/Object;",
  742. "T2:",
  743. "Ljava/lang/Object;",
  744. "T3:",
  745. "Ljava/lang/Object;",
  746. "T4:",
  747. "Ljava/lang/Object;",
  748. "T5:",
  749. "Ljava/lang/Object;",
  750. "T6:",
  751. "Ljava/lang/Object;",
  752. "T7:",
  753. "Ljava/lang/Object;",
  754. "T8:",
  755. "Ljava/lang/Object;",
  756. "R:",
  757. "Ljava/lang/Object;",
  758. ">(",
  759. "Lio/reactivex/functions/Function8<",
  760. "TT1;TT2;TT3;TT4;TT5;TT6;TT7;TT8;TR;>;)",
  761. "Lio/reactivex/functions/Function<",
  762. "[",
  763. "Ljava/lang/Object;",
  764. "TR;>;"
  765. }
  766. .end annotation
  767. const-string v0, "f is null"
  768. .line 123
  769. invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
  770. .line 124
  771. new-instance v0, Lio/reactivex/internal/functions/Functions$7;
  772. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$7;-><init>(Lio/reactivex/functions/Function8;)V
  773. return-object v0
  774. .end method
  775. .method public static toFunction(Lio/reactivex/functions/Function9;)Lio/reactivex/functions/Function;
  776. .locals 1
  777. .annotation system Ldalvik/annotation/Signature;
  778. value = {
  779. "<T1:",
  780. "Ljava/lang/Object;",
  781. "T2:",
  782. "Ljava/lang/Object;",
  783. "T3:",
  784. "Ljava/lang/Object;",
  785. "T4:",
  786. "Ljava/lang/Object;",
  787. "T5:",
  788. "Ljava/lang/Object;",
  789. "T6:",
  790. "Ljava/lang/Object;",
  791. "T7:",
  792. "Ljava/lang/Object;",
  793. "T8:",
  794. "Ljava/lang/Object;",
  795. "T9:",
  796. "Ljava/lang/Object;",
  797. "R:",
  798. "Ljava/lang/Object;",
  799. ">(",
  800. "Lio/reactivex/functions/Function9<",
  801. "TT1;TT2;TT3;TT4;TT5;TT6;TT7;TT8;TT9;TR;>;)",
  802. "Lio/reactivex/functions/Function<",
  803. "[",
  804. "Ljava/lang/Object;",
  805. "TR;>;"
  806. }
  807. .end annotation
  808. const-string v0, "f is null"
  809. .line 138
  810. invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
  811. .line 139
  812. new-instance v0, Lio/reactivex/internal/functions/Functions$8;
  813. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$8;-><init>(Lio/reactivex/functions/Function9;)V
  814. return-object v0
  815. .end method
  816. .method public static toMapKeySelector(Lio/reactivex/functions/Function;)Lio/reactivex/functions/BiConsumer;
  817. .locals 1
  818. .annotation system Ldalvik/annotation/Signature;
  819. value = {
  820. "<T:",
  821. "Ljava/lang/Object;",
  822. "K:",
  823. "Ljava/lang/Object;",
  824. ">(",
  825. "Lio/reactivex/functions/Function<",
  826. "-TT;+TK;>;)",
  827. "Lio/reactivex/functions/BiConsumer<",
  828. "Ljava/util/Map<",
  829. "TK;TT;>;TT;>;"
  830. }
  831. .end annotation
  832. .line 549
  833. new-instance v0, Lio/reactivex/internal/functions/Functions$ToMapKeySelector;
  834. invoke-direct {v0, p0}, Lio/reactivex/internal/functions/Functions$ToMapKeySelector;-><init>(Lio/reactivex/functions/Function;)V
  835. return-object v0
  836. .end method
  837. .method public static toMapKeyValueSelector(Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;)Lio/reactivex/functions/BiConsumer;
  838. .locals 1
  839. .annotation system Ldalvik/annotation/Signature;
  840. value = {
  841. "<T:",
  842. "Ljava/lang/Object;",
  843. "K:",
  844. "Ljava/lang/Object;",
  845. "V:",
  846. "Ljava/lang/Object;",
  847. ">(",
  848. "Lio/reactivex/functions/Function<",
  849. "-TT;+TK;>;",
  850. "Lio/reactivex/functions/Function<",
  851. "-TT;+TV;>;)",
  852. "Lio/reactivex/functions/BiConsumer<",
  853. "Ljava/util/Map<",
  854. "TK;TV;>;TT;>;"
  855. }
  856. .end annotation
  857. .line 571
  858. new-instance v0, Lio/reactivex/internal/functions/Functions$ToMapKeyValueSelector;
  859. invoke-direct {v0, p1, p0}, Lio/reactivex/internal/functions/Functions$ToMapKeyValueSelector;-><init>(Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;)V
  860. return-object v0
  861. .end method
  862. .method public static toMultimapKeyValueSelector(Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;)Lio/reactivex/functions/BiConsumer;
  863. .locals 1
  864. .annotation system Ldalvik/annotation/Signature;
  865. value = {
  866. "<T:",
  867. "Ljava/lang/Object;",
  868. "K:",
  869. "Ljava/lang/Object;",
  870. "V:",
  871. "Ljava/lang/Object;",
  872. ">(",
  873. "Lio/reactivex/functions/Function<",
  874. "-TT;+TK;>;",
  875. "Lio/reactivex/functions/Function<",
  876. "-TT;+TV;>;",
  877. "Lio/reactivex/functions/Function<",
  878. "-TK;+",
  879. "Ljava/util/Collection<",
  880. "-TV;>;>;)",
  881. "Lio/reactivex/functions/BiConsumer<",
  882. "Ljava/util/Map<",
  883. "TK;",
  884. "Ljava/util/Collection<",
  885. "TV;>;>;TT;>;"
  886. }
  887. .end annotation
  888. .line 606
  889. new-instance v0, Lio/reactivex/internal/functions/Functions$ToMultimapKeyValueSelector;
  890. invoke-direct {v0, p2, p1, p0}, Lio/reactivex/internal/functions/Functions$ToMultimapKeyValueSelector;-><init>(Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;)V
  891. return-object v0
  892. .end method