-
Observable.interval(0, 1, TimeUnit.SECONDS)
参数一:什么时候开始发送
参数二:隔多长时间发一次
参数三:计时的单位,是秒还是毫秒 -
.take(count)
发送验证码,到60肯定会停下来,总不能一直发射数据吧。take就是发射数据后控制什么时候停下来 -
.map
耳熟能详,就是用来把发射出去的值转换一下,转成你想要的。比如不用map,发射出的数据就是1,2,3,4,5, 使用了map,我在最终接收数据前,把发射的数据转换一下,就变成了 5,4,3,2,1 -
.doOnSubscribe
在 subscribe() 调用后而且在事件发送前执行;默认情况下, doOnSubscribe() 执行在 subscribe() 发生的线程
/**
* 发送验证码倒计时
*
* @param view
*/
public void sendVerfi(final View view) {
final int count = 5;
Observable.interval(0, 1, TimeUnit.SECONDS)
.take(count)
.map(new Function<Long, Long>() {
@Override
public Long apply(Long aLong) throws Exception {
return count - aLong;
}
})
.observeOn(AndroidSchedulers.mainThread())
.doOnSubscribe(new Consumer<Disposable>() {
@Override
public void accept(Disposable disposable) throws Exception {
view.setEnabled(false);
}
})
.subscribe(new Observer<Long>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(Long aLong) {
((Button) view).setText(aLong + "");
}
@Override
public void onError(Throwable e) {
}
@Override
public void onComplete() {
view.setEnabled(true);
}
});
}
网友评论