0

来自 Scala 中 Rx Observable 的 API 文档:

http://reactivex.io/rxscala/scaladoc/#rx.lang.scala.Observable

有两种应用方法,一种接受订阅者,另一种接受观察者。除了它们采用不同的类型来订阅 Observable 之外,这两种 apply 方法之间有什么区别?

4

1 回答 1

1

来自订阅者的文档

abstract class Subscriber[-T] extends Observer[T] with Subscription

Observer trait 的扩展,添加了订阅处理(取消订阅、isUnsubscribed 和添加方法)和背压处理(onStart 和请求方法)。

所以我们可以假设Observer'sapply是更通用的绑定,它可以接受一些代理或自定义观察者并实现观察者模式,而Subscriber'sapply是更有效的内部绑定。

有关详细信息,请参阅此问题

于 2015-05-28T09:01:24.340 回答