Как вернуть Object в методе, когда закончится работа RxJava?

Question

[Neonoviiwolf]

Доброго
Есть метод, он должен получить Object, когда закончит работу Rxjava, но не знаю как правильно сделать, сейчас я получаю при вызове NullPointerException.
Observable запрашивает данные из BD в io потоке, Observer создаёт экземпляр класса в главном потоке - это всё работает. Но как дождаться, чтобы метод ждал завершение работы запроса в бд, а не возвращал null
вот отрывок сокращённый

private DataTransferAddProduct addProduct;

    @Override
    public DataTransferAddProduct loadFromDB(int id_product) {

        Observable.create(observableEmitter -> {
        // тут происходит запрос
        }).subscribeOn(Schedulers.io())
                .observeOn(JavaFxScheduler.platform())
                .subscribe(o -> {
                    addProduct = (DataTransferAddProduct) o;
                });
/**return срабатывает до того, как  вызовется -  addProduct = (DataTransferAddProduct) o; */
        return addProduct; 
    }

Answer 1

[Денис Загаевский]

Ну можно вызвать toBlocking(), но это в корне неправильно. Возвращай дальше Observables, иначе нафига там вообще rx?

Comments

[Neonoviiwolf]

Да хочу враппер сделать, всю логику оставить в модели, а в контроллере не работать с ResultSet

[Денис Загаевский]

Neonoviiwolf, ммм, какой ещё ResultSet? И какая вообще связь?

[Neonoviiwolf]

Денис Загаевский, это курсор на JavaFx

[Исрапил Ахмедов]

Neonoviiwolf, вообще-то, он от java.sql

[Денис Загаевский]

Neonoviiwolf, и что? Ты, кажется, вообще смысла rx не понимаешь.

[Neonoviiwolf]

Денис Загаевский, само собой

[Денис Загаевский]

Neonoviiwolf, ну бери свой resultset, мапь его во что угодно, делай любую логику, и отдавай Observable.