sample of rxjava repeatWhen

java

    public static void main(String... args) {
        AtomicInteger a = new AtomicInteger();

        Observable.just(1, 2, 3, 4, 5, 6, 7, 8)
                .repeatWhen(notification -> {
                    return notification.flatMap(o -> {

                        System.out.println("'repeatWhen'");
                        if(a.getAndAdd(1) < 10){
                            return Observable.just(o).delay(1,TimeUnit.SECONDS);
                        }else{
                            return Observable.empty();
                        }
                    });

                })//
                .subscribe(System.out::println);

        while (true) ;

    }

Why should I need to put while (true) ; in the end? Isn't repeatWhen working without this?

Why should I need to put while (true) ; in the end? Isn't repeatWhen working without this?

This is to keep the program running.