benjchristensen

import java.util.concurrent.TimeUnit;

import rx.Observable;
import rx.Subscriber;

public class RetryWhenTests {

    public static void main(String[] args) {

        Observable.create((Subscriber<? super String> s) -> {