Доброго
Есть метод, он должен получить 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;
}
