Rxjava(创建类)--timer

Observable.timer(10, TimeUnit.SECONDS).subscribe(new Action1<Long>() {
@Override
public void call(Long aLong) {
log(aLong + "");
}
});

public static Observable<Long> timer(long delay, TimeUnit unit) {
return timer(delay, unit, Schedulers.computation());
}

public static Observable<Long> timer(long delay, TimeUnit unit, Scheduler scheduler) {
return create(new OnSubscribeTimerOnce(delay, unit, scheduler));
}

public void call(final Subscriber<? super Long> child) {
Worker worker = scheduler.createWorker();
child.add(worker);
worker.schedule(new Action0() {
@Override
public void call() {
try {
child.onNext(0L);
} catch (Throwable t) {
Exceptions.throwOrReport(t, child);
return;
}
child.onCompleted();
}
}, time, unit);
}