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