小编arc*_*ing的帖子

关于将SubscribeWith方法与返回的Subscriber一起使用

我想知道为什么该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
推荐指数
1
解决办法
3599
查看次数

标签 统计

rx-java ×1