rxjava
标签 rxjava 的文章
-
RxJava示例代码：Flowable示例
通常都是使用Observable创建事件，它发送数据好比是印度的火车站，车门一开一群人往上冲，车厢塞多少算多少。Flowable则好比非印度的火车站，车门口要排队，按座位量往里放行。 [crayon-6637ce3ef3d1c751801929/] - end
-
RxJava示例代码：异步启动多线程，每个线程内再顺序执行多个线程
场景：有10个人，给每人分配3个任务（砍树、打游戏、修自行车），任务是不能同时进行的。 要求：10个人同时开始执行任务，所有人都把3个任务完成后汇总结果。 分析：10个人的行为是异步的，理解为10个线程同时启动进行；每个人的任务是同步的，执行完一个才能进行下一个。 [crayon-6637ce3f0048c427815693/] end
-
RxJava示例代码：顺序不定时延迟执行任务
比如一队人去厕所，只能一个一个轮流进。每个人进去酝酿时长是不一样的，即不定时长的延迟。 [crayon-6637ce3f007f0824117649/] 一次记录： [crayon-6637ce3f00813029162615/] end
-
RxJava示例代码：数据源合并处理:startWith往前加1个、concatWith往后加1个、concat同步处理多个、merge异步处理多个、zip数据N和1
[crayon-6637ce3f00c03567443451/] - end
-
RxJava示例代码：错误拦截和重试
[crayon-6637ce3f0102b399327927/] - end
-
RxJava示例代码：isEmpty判断无数据、contains判断包含数据、all判断每个数据true、any判断有数据true
[crayon-6637ce3f013c4378413070/] - end
-
RxJava示例代码：map一对一转换、flatMap一对多无序、concatMap一对多有序、groupBy分组、buffer按量发射
[crayon-6637ce3f017a8530689659/] - end
-
RxJava示例代码：filter真假过滤、take次数限制、distinct重复过滤、elementAt位次限制
[crayon-6637ce3f01bbb864058920/] - end
-
RxJava示例代码：创建事件create、empty、just、fromArray、fromIterable、range
create、empty、just、fromArray、range接收原始数据，创建一个事件流“上游”的源头-“被观察者”。 [crayon-6637ce3f0205e682751447/] - end