Как удалить Disposable в RxJava 2.0 на Android? ⇐ Android

[Anonymous]

В приведенном ниже коде mSafeObserver.isDispose(); всегда возвращайте исключение нулевого указателя, если isDatabaseEmpty == false (

Код: Выделить всё

zipped.subscribe(mSafeObserver);

не вызывается).

Код: Выделить всё

private SafeObserver mSafeObserver;

private Observer observer = new Observer() {
// ...
}

@Override
public void onCreate(@Nullable Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
mSafeObserver = new SafeObserver(observer);
}

@Override
public void onViewCreated(View view, Bundle savedInstanceState) {
// ...
if (isDatabaseEmpty) {
zipped.subscribe(mSafeObserver);
} else {
initRecycler();
}
}

@Override
public void onDestroy() {
super.onDestroy();
if (mSafeObserver != null && !mSafeObserver.isDisposed())
mSafeObserver.dispose();
}

В rxJava 1.0 этот код правильный:

Код: Выделить всё

@Override
protected void onDestroy() {
super.onDestroy();
if (mSubscription != null && !mSubscription.isUnsubscribed())
mSubscription.unsubscribe();
}

Как проверить, могу ли я утилизировать одноразовые материалы?

Подробнее здесь: https://stackoverflow.com/questions/437 ... on-android