RXJava2-如何将使用者作为参数传入

Question

我正在Android中使用以下rxjava依赖项：

 compile 'io.reactivex.rxjava2:rxjava:2.1.0'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'

我正在尝试创建一个方法，它将把观察者作为参数。我有一些问题，我想是因为这是rxjava2，所以东西更新了，我有点困惑。

让我向你展示我想要完成的事情：

private Subscription subscription = Scriptions.empty(); //this isn't working. how to set a empty observer IN RXJAVA2?

protected abstract Observable buildUseCaseObservable(); //RETROFIT WILL BUILD THE OBSERVABLE FOR ME SOMEWHERE ELSE


public void execute(Consumer UseCaseSubscriber){
    this.subscription = this.buildUseCaseObservable()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(UseCaseSubscriber); //THIS LINE IS NOT WORKING , ERROR IS IN THE PHOTO
}

public void unsubscribe(){
    if(!subscription.isUnsubscribed()){
        subscription.unsubscribe();
    }
}

protected abstract Observable buildUseCaseObservable();

    @SuppressWarnings("unchecked")
    public void execute(Observer UseCaseSubscriber){
        this.subscription = this.buildUseCaseObservable()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(UseCaseSubscriber);
    }

    public void unsubscribe(){
        if(!subscription.isUnsubscribed()){
            subscription.unsubscribe();
        }
    }

那么如何保存一次性，这样我们就可以退订了呢？

Answer 1

订阅已“重命名”为2.x版本的一次性。您可以在这里阅读有关此更改的rxJava wiki解释。

那么如何保存一次性，这样我们就可以退订了呢？flowable.subscribe(Subscriber)不返回disposable,但observable.subscribe(Subscriber)返回。如果不需要背压，只需使用.toobservable()将flowable转换为observable。