Interval Operator RxJava

RxOperatorInterval.java

public class RxOperatorInterval {
    public static void main(String[] args) throws InterruptedException {
        CountDownLatch countDownLatch = new CountDownLatch(1);
        Observable.interval(1000 * 2, TimeUnit.MILLISECONDS)
                .subscribe(new Observer<Long>() {
                    @Override
                    public void onSubscribe(Disposable d) {
                        System.out.println("onSubscribe");
                    }

                    @Override
                    public void onNext(Long count) {
                        String now = new SimpleDateFormat("HH:mm:ss", Locale.US).format(new Date());
                        System.out.println(now + " onNext: " + count);
                        if (count == 5) {
                            onComplete();
                        }
                    }

                    @Override
                    public void onError(Throwable e) {
                        System.out.println("onError");
                    }

                    @Override
                    public void onComplete() {
                        System.out.println("onComplete");
                        countDownLatch.countDown();
                    }
                });
        countDownLatch.await();
    }
}