mDisposables.add(mTasksRepository.createAuthorize(rBody)
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(loginResponse -> {
        Timber.i("createAuthorizeSuccess");
    }, throwable -> {
        Timber.e("createAuthorizeError");
    }));

RxJava 2 propose plusieurs classes de base sur lesquelles vous pouvez découvrir des opérateurs :

• io.reactivex.Flowable : 0..N flux, prenant en charge les flux réactifs et la contre-pression

• io.reactivex.Observable : 0..N débits, pas de contre-pression

• io.reactivex.Single : un flux d'exactement 1 article ou une erreur

• io.reactivex.Completable : un flux sans éléments mais seulement un signal de fin ou d'erreur

• io.reactivex.Maybe : un flux sans éléments, avec exactement un élément ou une erreur

取消订阅可以试试 RxLifecycle https://github.com/trello/RxL...，使用起来很方便。