class ObservableFromCallable extends Observable<T> implements Callable<T> {

    @Override
    public T call() throws Exception {
        return ObjectHelper.requireNonNull(callable.call(), "The callable returned a null value");
    }

    public  ObservableFromCallable(Callable<? extends T> callable);

}