编辑 :@Alrid的评论
tl; dr
public abstract class Subscriber<T> implements Observer<T>, Subscription
因此,订阅服务器是Observer的实现,在订阅上具有其他语义(更多关于取消订阅)。您问题中的代码只是表明它通过了
Observer接口,而不是实现(通常是编程实践)。
此代码还返回一个
Subscription,这可能是因为该代码的作者认为客户端应该只能访问
Subscription方法,而不能访问可观察对象产生的元素。那可能是程序员错误。
很长的故事
真的是你应该阅读本网站内容(或预订):http://www.introtorx.com
是关于Rx.Net,但其概念是非常相同的,它们是由埃里克·梅杰和RxJava实施者创建跟着他们(
(如果适用于Java语言)。
此页面将使您感兴趣(这是第二章):KeyTypes
在这里,您将阅读第一段:
使用Rx时需要了解两种主要类型,以及一些辅助类型的子集,它们可以帮助您更有效地学习Rx。IObserver和IObservable构成了Rx的基本构建块,而ISubject的实现减少了Rx初学者的学习难度。
…
Rx本质上是建立在Observer模式的基础上的。.NET已经公开了实现观察者模式的其他方法,例如多播委托或事件(通常是多播委托)。
即使类型/ API有所不同,您也可以从这本书中学到很多东西,可能比从一些博客中学到的更多。
这 本书 没有说什么( …因为它在RxJava实现中 )
RxJava的主要开发人员此时引入了一些细微的变化(请参阅PR
#792),从而可以区分两种类型的合同:
- 通知->
Observer
- 订阅->
Subscription
这项更改可以更好地表达/分割RxJava库实现类的这些问题。
但是,作为库用户,使用RxJava库的实际实现应该足够好。
实现订户需要更多的知识,工作和维护,实际上,订户的语义非常重要,具体取决于可观察到的源的类型(热还是冷?创建昂贵?)
在大多数情况下,公开
Subscriber而不是
Observer在上述情况下不会干扰代码,但是除非需要那些取消订阅的语义,否则它不是预期的用途。但最终实施
Subscriber和可能涉及陷入一些陷阱,例如:
- 将资源用于您不会使用的功能
- 不能从另一个类继承
- 输入不正确的退订代码
- 复制/粘贴代码不正确的代码或为其他上下文编写的正确代码



