作者博客
http://www.jianshu.com/u/c50b715ccaeb
前言
在上一节中, 我们学习了Flowable的一些基本知识, 同时也挖了许多坑, 这一节就让我们来填坑吧....可能有朋友也注意到了, 之前使用Observable测试的时候内存增长非常迅速, 几秒钟就OOM, 但这里增长速度却比较缓慢, 可以翻回去看之前的文章中的GIF图进行对比, 这也看出Flowable相比...想想看我们之前学习Observable的时候说到的如何解决上游发送事件太快的, 有一招叫从数量上取胜, 同样的Flowable中也有这种方法, 对应的就是BackpressureStrategy.DROP..., 当我们request(128)的时候,下游便会处理掉这128个事件, 那么上游水缸中又会重新装进新的128个事件, 以此类推, 来看看运行结果吧:
从运行结果中我们看到的确是如此, 第一次request...比如RxJava中的interval操作符, 这个操作符并不是我们自己创建的, 来看下面这个例子吧:
interval操作符发送Long型的事件, 从0开始, 每隔指定的时间就把数字加1并发送出来, 在这个例子里