RxJava2 helper classes

MainThreadSchedule.java

import io.reactivex.Observable;
import io.reactivex.ObservableSource;
import io.reactivex.ObservableTransformer;
import io.reactivex.android.schedulers.AndroidSchedulers;

/**
 * @author Aleks Sander
 */

public final class MainThreadSchedule<Stream> implements ObservableTransformer<Stream, Stream> {

    private MainThreadSchedule(){
        //private empty
    }

    public static <Stream> MainThreadSchedule<Stream> create() {
        return new MainThreadSchedule<>();
    }

    @Override
    public ObservableSource<Stream> apply(Observable<Stream> upstream) {
        return upstream.subscribeOn(AndroidSchedulers.mainThread()).observeOn(AndroidSchedulers.mainThread());
    }
}

OperatorIfThen.java

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.exceptions.Exceptions;
import io.reactivex.functions.BooleanSupplier;
import io.reactivex.internal.disposables.EmptyDisposable;

public final class OperatorIfThen<R> extends Observable<R> {
    private final BooleanSupplier condition;
    private final Observable<? extends R> then;
    private final Observable<? extends R> orElse;

    public OperatorIfThen(BooleanSupplier condition, Observable<? extends R> then, Observable<? extends R> orElse) {
        this.condition = condition;
        this.then = then;
        this.orElse = orElse;
    }

    @Override
    protected void subscribeActual(Observer<? super R> observer) {
        boolean b;

        try {
            b = condition.getAsBoolean();
        } catch (Throwable ex) {
            Exceptions.throwIfFatal(ex);
            EmptyDisposable.error(ex, observer);
            return;
        }

        if (b) {
            then.subscribe(observer);
        } else {
            orElse.subscribe(observer);
        }
    }
}