Different RxJava utilities

TransformerMapCatch.java

package com.ebooks.ebookreader.utils.rx;

import rx.Observable;

public class TransformerMapCatch<T, R> implements Observable.Transformer<T, R> {
	private FuncThrowable1<? super T, ? extends R> mFunc;

	public TransformerMapCatch(FuncThrowable1<? super T, ? extends R> func) {
		mFunc = func;
	}

	@Override
	public Observable<R> call(Observable<T> rObservable) {
		return rObservable.flatMap(object -> {
			try {
				return Observable.just(mFunc.call(object));
			} catch (Throwable e) {
				return Observable.error(e);
			}
		});
	}
}

Usage.java

package example;

import rx.Observable;
import rx.schedulers.Schedulers;

import static com.ebooks.ebookreader.utils.rx.UtilsRx.mapCatch;

...
Observable.just(node)
		.compose(mapCatch(node -> new FileOutputStream(pair.second)))
...

UtilsRx.java

package com.ebooks.ebookreader.utils.rx;

import android.util.Pair;

import rx.Observable;

public final class UtilsRx {
	private UtilsRx() {}

	public static <T, R> Observable.Transformer<T, R> mapCatch(FuncThrowable1<? super T, ? extends R> func) {
		return new TransformerMapCatch<>(func);
	}
}