来自 Scala 中 Rx Observable 的 API 文档:
http://reactivex.io/rxscala/scaladoc/#rx.lang.scala.Observable
有两种应用方法,一种接受订阅者,另一种接受观察者。除了它们采用不同的类型来订阅 Observable 之外,这两种 apply 方法之间有什么区别?
来自 Scala 中 Rx Observable 的 API 文档:
http://reactivex.io/rxscala/scaladoc/#rx.lang.scala.Observable
有两种应用方法,一种接受订阅者,另一种接受观察者。除了它们采用不同的类型来订阅 Observable 之外,这两种 apply 方法之间有什么区别?
来自订阅者的文档:
abstract class Subscriber[-T] extends Observer[T] with Subscription
Observer trait 的扩展,添加了订阅处理(取消订阅、isUnsubscribed 和添加方法)和背压处理(onStart 和请求方法)。
所以我们可以假设Observer
'sapply
是更通用的绑定,它可以接受一些代理或自定义观察者并实现观察者模式,而Subscriber
'sapply
是更有效的内部绑定。
有关详细信息,请参阅此问题。