Prints "The timer was called!" and the response body to a www.google.com request every second in Java using rxjava

async_timer.java

import org.asynchttpclient.*;
import org.asynchttpclient.extras.rxjava.*;
import rx.Observable;
import java.util.concurrent.TimeUnit;

public class Main {
    public static void main(String[] args) {
        AsyncHttpClient client = new DefaultAsyncHttpClient();
        Observable<Long> timer = Observable.timer(1, 1, TimeUnit.SECONDS);

        Observable<Response> timedRequests = timer.flatMap(id ->
                AsyncHttpObservable.toObservable(() -> client.prepareGet("http://www.google.com")));

        timer.subscribe(id -> System.out.println("The timer was called!"));
        timedRequests.subscribe(
                resp -> System.out.println(resp.getResponseBody()),
                err -> System.err.println("RIP: " + err)
        );
    }
}