我想知道为什么该subscribeWith方法会返回Subscriber而不是严格讲Disposable或Subscription。
我认为该subscribeWith方法是为使用RxJava 1.x的subscribe返回Subscription 的方法而设计的。因此,在2.0中,我认为subscribeWithmethod 的主要用法将是与实现Disposable的Subscriber一起使用。
但是,由于该subscribeWith方法可以返回订阅服务器,因此可能会发生类似主题的用法(例如以下代码)。
Subscriber<Long> subscriber = Flowable.interval(100, TimeUnit.MILLISECONDS)
.subscribeWith(new Subscriber<Long>() {
...
});
...
subscriber.onNext(999);
...
Run Code Online (Sandbox Code Playgroud)
这样可以还是我不应该做的事情?
rx-java ×1