Simple looping Observable with sleep interval and timeout. Actually getting an item would replace the line with i++

ShowItem.java

import io.reactivex.Observable;
import java.util.concurrent.TimeUnit;

/**
 * Created by mmynsted on 2/8/17.
 */
public class ShowItem {

    public void printItem() {
        int timeoutSecs = 5;
        int sleepTime = 1000;

        //create an observable that keeps trying to get an item
        Observable<Integer> x = Observable.fromCallable(() -> {
            int i = 0;
            while (!isValid(i)) { //testing the item
                Thread.sleep(sleepTime);
                i++;              //getting the item
            }
            return i;
        }).timeout(timeoutSecs, TimeUnit.SECONDS);

        //show it
        x.subscribe(System.out::println);
    }

    private static boolean isValid(int in) {
        return (in > 1);
    }
}