rxjava example

gistfile1.md

Observable<Entry<GeoCircleValue<String>> results = tree.search(...);
results
    //get just the name of the city
    .map( entry -> entry.value().value)
    //get the populations asynchronously
    .flatMap(name -> Observable.just(name)
                               .map(n -> new NameAndPop(n, service.populationOf(n))
                               .subscribeOn(Schedulers.io()))
    //observe the results on current thread
    .observeOn(Schedulers.immediate())
    //write the name and the population to the servlet writer
    .subscribe(Subscribers.create(namePop -> out.println(<"p>" + namePop.name() + " " + namePop.pop() + "</p>"));