RxFuturoid.java

import com.github.clemp6r.futuroid.Async;
import com.github.clemp6r.futuroid.Future;

import java.util.concurrent.Callable;

import rx.Observable;
import rx.subjects.PublishSubject;

/**
 * Helper for integrating Futuroid with Rx.
 */
public class RxFuturoid {

    /**
     * Creates a Futuroid async task wrapped by an Rx Observable.
     */
    public static <T> Observable<T> start(Callable<T> task) {
        PublishSubject<T> subject = PublishSubject.create();

        Future<T> future = Async.submit(task);

        future.addSuccessCallback(result -> {
            subject.onNext(result);
            subject.onCompleted();
        });

        future.addFailureCallback(t -> {
            subject.onError(t);
            subject.onCompleted();
        });

        return subject;
    }
}