神刀安全网

RxSwift翻译(二)—— Subject

Subject

Subject是一种桥梁和代理,在ReactiveX的一些实现中,它既可以当作observer也可以当做Observable。因为它是一个observer,所以它可以订阅一个或多个Observable,同时因为它是一个Observable,它可以传递它观察到的事件,重新发送他们,它也可以发送新的事件。

当Subject订阅一个Observable时,它可以触发Observable发送事件(如果那是一个“cold” Observable,以为“cold” Observable会在被订阅之后开始发送信息)。这一特点可以让Subject成为一个“hot”Observable,这个“hot” Observable是一种原来“cold”Observable的变体。

有四种不同用途的的Subject,不是这四种Subject都会在ReactiveX的所有实现中出现,不同的语言都会有自己的命名规范,会略有不同。

AsyncSubject

RxSwift翻译(二)—— Subject

AsyncSubject只发送由源Observable发送的最后一个事件,并且只在源Observable完成之后。(如果源Observable没有发送任何值,AsyncSubject也不会发送任何值。)

RxSwift翻译(二)—— Subject

AsyncSubject会发送相同的值给所有observer。但是,如果源Observable被一个error中断了发送,AsyncSubject不会发送任何事件,而是会发送从源Observable传来的error提示。

BehaviorSubject

RxSwift翻译(二)—— Subject

当一个observer订阅一个BehaviorSubject,它就开始发送最近由源Observable发送的事件(或者是还没有被发送的种子值/默认值)然后继续发送从源Observable接收到的其他事件。

RxSwift翻译(二)—— Subject

如果源Observable被一个error中断,那么BehaviorSubject不会发送事件给后续的observer,但会传递给他们error的信息。

PublishSubject

RxSwift翻译(二)—— Subject

PublishSubject仅仅发送在订阅之后由源Observable发送的数据。

PublishSubject一旦被建立就会立刻开始发送事件(除非你采取一些方法去阻止它),这种机制有丢失事件的风险,因为在Subject被创建和被监听之间有一定的时间间隔。如果你想保证所有的事件都可以被监听到的话,你有两种方法。第一种是用Create方法(在发送之前检查是否所有observer已经订阅好了)。第二种方法是你可以使用ReplaySubject。

RxSwift翻译(二)—— Subject

如果源Observable被一个error中断,PublishSubject将不会发送任何事件给后续的observer,但是它会传递error信息。

ReplaySubject

RxSwift翻译(二)—— Subject

ReplaySubject发送源Observable的所有事件无论observer什么时候开始订阅。

也有一些版本的ReplaySubject会在缓存中的事件数达到一定的值时丢掉一些事件,或者在某一个时间段之后丢掉一些缓存的事件。

如果把ReplaySubject当做一个观察者,注意不要从多个线程中调用onNext方法(或者其他on方法),因为这样的调用会导致非序列,ReplaySubject可能会弄不清楚哪个时间应该首先被replay。

原文链接

转载本站任何文章请注明:转载至神刀安全网,谢谢神刀安全网 » RxSwift翻译(二)—— Subject

分享到:更多 ()

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址