RxJava 学习进行中-Scan&Debounce&ThrottleWithTimeout

RX

1.Scan

连续地对数据序列的每一项应用一个函数,然后连续发射结果
操作符对原始Observable发射的第一项数据应用一个函数,然后将那个函数的结果作为自己的第一项数据发射。它将函数的结果同第二项数据一起填充给这个函数来产生它自己的第二项数据。它持续进行这个过程来产生剩余的数据序列。这个操作符在某些情况下被叫做accumulator

看完文档,感觉Scan叫的太牵强,不过自己也想不出别这个更好的词来,当然accumulator更加得形象。它接受的参数可以只是一个固定有两个参数一个输出的Func2<>

        Character[] strs = {'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h','i'};
        Observable<Character> origin = Observable.from(strs);

        origin.scan("",new Func2<String, Character, String>() {

            @Override
            public String call(String s, Character character) {
                String result = s+character.charValue();
                Log.d("scan","拼接字符 "+s +" + "+character.charValue() +" = " +result);
                return result;
            }
        }).subscribe(new Subscriber<String>() {
            @Override
            public void onCompleted() {

            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onNext(String result) {
                Log.d("scan","接收到的 result = "+result);
            }
        });

可以看到Scan还有一个参数,这里是一个空字符串,这是另一种形式,第一个参数是你预先设定好的初值,第二个参数则是你的函数,初值会作为第一个值加入到方法中去。

注意

A = C , B随意
    scan("",new Func2<A, B, C>() {
            @Override
            public C call(A a,  B b) {
                return .....;
            }
        })

这是因为Scan会接受上一个scan返回值作为第一个参数,当然如果你写不一样了,AS会提醒你的,一片红色波浪线...

运行结果

2.Debounce & ThrottleWithTimeout

先贴上官方说明

仅在过了一段指定的时间还没发射数据时才发射一个数据,会过滤掉发射速率过快的数据项。

一开我的理解是这样的,在一定时间段内发送在这个时间段内输出的最后一个数据

如下图

错误的理解

于是乎,我写了以下代码做测试

        Observable.interval(1, TimeUnit.SECONDS)//每隔1秒发送一个Long型的从0自增的数
                .debounce(3, TimeUnit.SECONDS)
                .subscribe(new Action1<Long>() {
                    @Override
                    public void call(Long aLong) {
                        Log.d("debounce","aLong num = "+aLong);
                    }
                });

然而,打印出来的是一片空白。啥都没有!我懵逼了,跟想象中不一样啊!

于是乎请教了搜索引擎,找到呼啸而过11写的代码

   Observable.create(new Observable.OnSubscribe<Integer>() {
        @Override
        public void call(Subscriber<? super Integer> subscriber) {
            if(subscriber.isUnsubscribed()) return;
            try {
                //产生结果的间隔时间分别为100、200、300...900毫秒
                for (int i = 1; i < 10; i++) {
                    subscriber.onNext(i);
                    Thread.sleep(i * 100);
                }
                subscriber.onCompleted();
            }catch(Exception e){
                subscriber.onError(e);
            }
        }
    }).subscribeOn(Schedulers.newThread())
            .debounce(400, TimeUnit.MILLISECONDS)  //超时时间为400毫秒
            .subscribe(
                    new Action1<Integer>() {
                        @Override
                        public void call(Integer integer) {
                            Log.d("debounce","onnext aLong num = "+integer);
                        }
                    }, new Action1<Throwable>() {
                        @Override
                        public void call(Throwable throwable) {
                            Log.d("debounce","onerror ");
                        }
                    }, new Action0() {
                        @Override
                        public void call() {
                            Log.d("debounce","oncompleted ");
                        }
                    });

运行结果如下:
Next:4
Next:5
Next:6
Next:7
Next:8
Next:9
completed!

恍然大悟,其真正含义是在输出了一个数据后的一段时间内,没有再次输出新的数据,则把这个数据真正的发送出去;假如在这段时间内有新的数据输出,则以这个数据作为将要发送的数据项,并且重置这个时间段,重新计时。

正确的理解

我把之前的测试代码按照我的理解修改了一下

/**debounce设置时间间隔为3秒,interval每一秒发送一个数据项,中间用filter过滤掉了第1、2、3,6、
7,11、12、13、14秒的数据项,就是为了看第0项,第5项,第10项能否发送,按理解,在3秒的时间间隔
内没有新数据项到达才会发送最后一个数据项,即0、10项是可以被发送的,而5不可以;y以及使用map打印
出真正到达debounce的数据项,方便理解
*/
        Observable.interval(1, TimeUnit.SECONDS)//每隔1秒发送一个Long型的从0自增的数
                .filter(new Func1<Long, Boolean>() {
                    @Override
                    public Boolean call(Long aLong) {

                        if(aLong==1) return false;
                        if(aLong==2) return false;
                        if(aLong==3) return false; //发送0

                        if(aLong==6) return false;
                        if(aLong==7) return false; //不能发送5

                        if(aLong==11) return false;//发送 10
                        if(aLong==12) return false;
                        if(aLong==13) return false;
                        if(aLong==14) return false;
                        return true;
                    }
                })
                .map(new Func1<Long, Long>() {

                    @Override
                    public Long call(Long aLong) {
                        Log.d("debounce","发送了 "+aLong);
                        return aLong;
                    }
                })
                .debounce(3, TimeUnit.SECONDS)
                .subscribe(new Action1<Long>() {
                                @Override
                                public void call(Long aLong) {
                                    Log.d("debounce","aLong num = "+aLong);
                                }
                            });

运行结果

Debounce有另一种形式,使用一个Func1<?, Observable<?>>的函数来限制发送的数据。

来自bobo_wang的代码

   Observable.just(1, 2, 3, 4, 5, 6, 7, 8, 9)
            .debounce(new Func1<Integer, Observable<Integer>>() {
                          @Override
                          public Observable<Integer> call(final Integer integer) {
                              return Observable.create(new Observable.OnSubscribe<Integer>() {
                                  @Override
                                  public void call(Subscriber<? super Integer> subscriber) {
                                      //如果%2==0,则发射数据并调用了onCompleted结束,则不会被丢弃
                                      if (integer % 2 == 0 && !subscriber.isUnsubscribed()) {
                                          subscriber.onNext(integer);
                                          subscriber.onCompleted();
                                      }
                                  }
                              });
                          }
                      }).observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Action1<Integer>() {
                @Override
                public void call(Integer integer) {
                    Log.d("debounce","integer = "+integer);
                }
            });

输出为
debounce:2
debounce:4
debounce:6
debounce:8
debounce:9

ThrottleWithTimeout则只有跟使用时间参数来限流的Debounce一样的功能。

这两个操作符的理解没有那么容易,需要写多几个例子来加深自己的印象。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 216,496评论 6 501
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,407评论 3 392
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 162,632评论 0 353
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,180评论 1 292
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,198评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,165评论 1 299
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,052评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,910评论 0 274
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,324评论 1 310
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,542评论 2 332
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,711评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,424评论 5 343
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,017评论 3 326
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,668评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,823评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,722评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,611评论 2 353

推荐阅读更多精彩内容

  • 注:只包含标准包中的操作符,用于个人学习及备忘参考博客:http://blog.csdn.net/maplejaw...
    小白要超神阅读 2,193评论 2 8
  • 作者: maplejaw本篇只解析标准包中的操作符。对于扩展包,由于使用率较低,如有需求,请读者自行查阅文档。 创...
    maplejaw_阅读 45,661评论 8 93
  • 版权声明:本文为小斑马伟原创文章,转载请注明出处! 上篇简单的阐述了响应式编程的基本理论。这篇主要对响应编程进行详...
    ZebraWei阅读 2,314评论 0 2
  • 注:只包含标准包中的操作符,用于个人学习及备忘参考博客:http://blog.csdn.net/maplejaw...
    小白要超神阅读 927评论 0 3
  • 响应式编程简介 响应式编程是一种基于异步数据流概念的编程模式。数据流就像一条河:它可以被观测,被过滤,被操作,或者...
    说码解字阅读 3,066评论 0 5