RxJava группирует два ответа, один из которых может быть NULL с оператором zip - PullRequest
Новая
       38

RxJava группирует два ответа, один из которых может быть NULL с оператором zip

0 голосов
/ 14 мая 2018

Я хочу сделать два параллельных запроса к базе данных Realm и вернуть результаты с помощью RxJava.Проблема в том, что один из запросов может вернуть объект NULL, и у меня происходит сбой.Как я могу правильно вернуть результаты из обеих БД, даже если один из них NULL?Спасибо. 

public void getDataFromTwoSources(DisposableObserver<ComplexUserDto> observer, String shopId) {
        Preconditions.checkNotNull(observer);

        final Observable<ComplexUserDto> observable = Observable.zip(firstRepository.getUserData(userId), secondRepository.getUserDetailData(userId),
                (userData, userDetails) -> {
                    ComplexUserDto resultDto = new ComplexUserDto(userData, userDetails);
                    return resultDto;
                })
                .compose(rxTransformers.applyUnauthorizedHandler())
                .compose(rxTransformers.applySchedulers());
        addDisposable(observable.subscribeWith(observer));
    }

public class ComplexUserDto {
    private UserData userData;
    private UserDetailData userDetailData;

    public ComplexUserDto(UserData userData, UserDetailData userDetailData) {
        this.userData = userData;
        this.userDetailData = userDetailData;
    }

    public UserData getUserData() {
        return userData;
    }

    public UserDetailData getUserDetailData() {
        return userDetailData;
    }
}

Исключение: 

java.lang.NullPointerException: onNext called with null. Null values are generally not allowed in 2.x operators and sources.
        at io.reactivex.internal.operators.observable.ObservableCreate$CreateEmitter.onNext(ObservableCreate.java:63)
        at com.yozhik.data.database.shop.RealmDatabaseManagerImpl.lambda$null$15$RealmDatabaseManagerImpl(RealmDatabaseManagerImpl.java:261)
        at com.yozhik.data.database.shop.RealmDatabaseManagerImpl$$Lambda$15.execute(Unknown Source)
        at io.realm.Realm$1.run(Realm.java:1502)
        at io.realm.internal.async.BgPriorityRunnable.run(BgPriorityRunnable.java:34)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:422)
        at java.util.concurrent.FutureTask.run(FutureTask.java:237)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1112)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:587)
        at java.lang.Thread.run(Thread.java:818)

1 Ответ

0 голосов
/ 20 мая 2018

Вы можете вернуть Optional из БД и затем проверить, присутствует ли он.

...