android - 在 RxJava 2.0 中订阅 PublishSubject

Question

我有以下在 RxJava 1.6 中完美运行的代码。

private PublishSubject<Boolean> mConnectionSubject;
...
Observable.create(subscriber -> {
        mConnectionSubject.subscribe(subscriber);
        ...
    });

但是在迁移到 RxJava 2.0 之后，这段代码无法编译。原因是 Observable.create() 现在接受 ObservableEmitter 作为参数。但是 PublishSubject 不接受 ObservableEmitter。它只接受 Consumer 或 Observer 接口(interface)。

将不胜感激任何建议。

Answer 1

在您提到的场景中，我会做类似下面的事情。

Observable.<Boolean>create(emitter -> mConnectionSubject.subscribe(
    emitter::onNext,
    emitter::onError,
    emitter::onComplete
));