0ximDigital

Here is our FavouriteArticleUseCase:

public final class FavouriteArticleUseCase implements CompletableUseCase<Integer> {

    private final FeedRepository feedRepository;

    public FavouriteArticleUseCase(final FeedRepository feedRepository) {
        this.feedRepository = feedRepository;
    }

0ximDigital

public static void main(String[] args) throws InterruptedException {

        Observable.zip(stringObservable().subscribeOn(Schedulers.io()),
                integerObservable().subscribeOn(Schedulers.io()),
                (s, integer) -> {
                    timedLog("Got items, zipping");
                    return s + " " + String.valueOf(integer);
                })
                .subscribeOn(Schedulers.io())
                .observeOn(Schedulers.computation())