Являются ли одноразовые в методе "doOnSubscribe" и одноразовые, возвращенные методом "подписки", отличаются? - PullRequest
Новая
       9

Являются ли одноразовые в методе "doOnSubscribe" и одноразовые, возвращенные методом "подписки", отличаются?

0 голосов
/ 20 ноября 2018

У меня BaseViewModel как: 

public class BaseViewModel extends ViewModel {

private MutableLiveData<ApiError> apiError = new MutableLiveData<>();
private MutableLiveData<ApiProgress> apiProgress = new MutableLiveData<>();
private CompositeDisposable compositeDisposable = new CompositeDisposable();

// Emit "progress's start" on subscribe and "progress's end" on after success or error.
// Add this to the observable action sequence with ".compose(baseTransformer())" before subscribe.
<T> SingleTransformer<T, T> baseTransformer() {
    return upstream -> upstream
            .doOnSubscribe(disposable -> {
                Log.d("dis", "doOnSubscribe : " + disposable + " " + disposable.isDisposed());
                compositeDisposable.add(disposable);
                apiProgress.setValue(ApiProgress.start());
            })
            .doOnDispose(() -> Log.d("dis", "I am disposed.."))
            .doFinally(() -> apiProgress.setValue(ApiProgress.stop()))
            .doOnError(err -> {
                apiError.setValue(ApiError.create(err));
            });
}

public LiveData<ApiError> getApiError() {
    return apiError;
}

public LiveData<ApiProgress> getApiProgress() {
    return apiProgress;
}

@Override
protected void onCleared() {
    super.onCleared();
    if (!compositeDisposable.isDisposed()) {
        compositeDisposable.dispose();
        Log.d("dis", "compositeDisposable disposed");
    }
}
}

и LoginViewModel как: 

public class LoginViewModel extends BaseViewModel {

Disposable disposable;
private AuthRepository authRepository;
private MutableLiveData<Login> loginData = new MutableLiveData<>();

public LoginViewModel() {
    authRepository = new AuthRepository();
}

public LiveData<Login> getLoginData() {
    return loginData;
}

public void login(String userName, String password) {
    disposable = authRepository.login(userName, password)
            .compose(baseTransformer())
            .subscribe(login -> loginData.setValue(login), err -> {
            });
}

@Override
protected void onCleared() {
    super.onCleared();
    Log.d("dis", "LoginViewModel : " + disposable + " " + disposable.isDisposed());
}
}

Я хочу избавиться от одноразового использования, возвращенного методом подписки, но я хочу сделать это в преобразованиитак, мне не нужно делать это каждый раз.

Я получил следующий вывод в журналах: 

D/dis: doOnSubscribe : null false
D/dis: compositeDisposable disposed
D/dis: LoginViewModel : 0 false

Пожалуйста, помогите мне понять: почему одноразовые изделия не утилизируются даже послеКомпозитныйУдно утилизируется успешно.

1 Ответ

0 голосов
/ 21 ноября 2018

Я достиг этой цели, добавив новый метод 

<T> void consumeApi(Single<T> apiSingle, Consumer<T> consumer) {
    compositeDisposable.add(apiSingle
            .compose(baseTransformer())
            .subscribe(accept(consumer))
    );
}

в BaseViewModel.Теперь мне просто нужно позвонить 

consumeApi(
            authRepository.login(userName, password),
            login -> loginData.setValue(login)
    );

в LoginViewModel.

...