Quiz

Which of the following blocking operators should replace X in the code below?

Observable<Long> source =  Observable.interval(1, TimeUnit.SECONDS).take(10);;        
Iterable<Long> iter = source.X;         
for (Long i: iter) {System.out.println(i);}