RxJava實現(xiàn)指定時間內(nèi)的點擊計數(shù)

RxView.clicks(rl).map(new Function<Object, Integer>() {
    @Override
    public Integer apply(Object o) throws Exception {
        return 1;
    }
}).scan(new BiFunction<Integer, Integer, Integer>() {
    @Override
    public Integer apply(Integer integer, Integer integer2) throws Exception {
        return ++integer;
    }
}).sample(3, TimeUnit.SECONDS).subscribe(new Consumer<Integer>() {
    @Override
    public void accept(Integer integer) throws Exception {
        //差值即為點擊次數(shù)
        Log.i("lpc", "" + (integer - defaultVlaue));
        //重新賦值,作為下一次的減數(shù)
        defaultVlaue = integer;
    }
});

defaultValue初始值為0

最后編輯于
?著作權歸作者所有,轉載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

相關閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容