浙江建设监理协会网站,dedecms做国外网站,网站建设 月光博客,云南做企业建站在RxJS#xff08;Reactive Extensions for JavaScript#xff09;中#xff0c;Subject、BehaviorSubject、ReplaySubject和AsyncSubject都是Observable的变体#xff0c;它们用于处理观察者模式中的不同场景。以下是它们之间的主要区别#xff1a;
1、Subject: 是一种特…在RxJSReactive Extensions for JavaScript中Subject、BehaviorSubject、ReplaySubject和AsyncSubject都是Observable的变体它们用于处理观察者模式中的不同场景。以下是它们之间的主要区别
1、Subject: 是一种特殊的Observable同时也是观察者。可以通过调用next()方法向Subject中推送新的值。 在订阅Subject时可以接收到订阅之后产生的值。 没有初始值也没有缓存历史值的功能。 上面例子就比较容易理解
我们创建了一个Subject发出了一个值1但由于此时并没有订阅者所以这个值不会被订阅到创建了订阅者 A又发出一个值 2这时候订阅者 A 会接收到这个值又创建一个订阅者 B最后发出一个值 3这时候已经订阅的都会接收到这个值
2、BehaviorSubject: 是一种特殊的Subject具有初始值。 在订阅时会立即收到当前的值然后在之后每次Subject发出新值时订阅者都会收到更新后的值。 保留并提供对当前值的访问。 这段代码做了那些工作呢
我们首先创建了一个BehaviorSubject的实例behavior$,并在实例化时传入初始值 0。然后我们订阅了这个这个实例behavior$,由于BehaviorSubject的特点是把最新的值发布给订阅者订阅者 A 会得到初始值 0所以就会打引出订阅者 A订阅值为0behavior$使用内置的next方法发出一个新的值 1这时候订阅者 A 将会收到新的值打印出订阅者 A订阅值为 1我们增加一个订阅者 B这时候它会得到最新的值 1所以打印结果为订阅者B订阅值为 1最后我们再一次调用behavior$的next方法由于我们之前已经订阅了两次所以订阅者 A 和订阅者 B 都会接收到新的value
3、ReplaySubject 会在订阅时接收一定数量的历史值缓存。 可以指定缓存的大小当新的值推送到ReplaySubject时最早的值会从缓存中移除。 适用于需要让订阅者获取历史值的场景。 这里发生了一些事情
我们创建了一个ReplaySubject的实例replay$并指定我们只想存储最后两个值我们创建了一个订阅者 A调用三次replay$的next方法把值发布给订阅者。这时订阅者 A 将会打印三次现在就来体验ReplaySubject的魔力。我们使用replay$创建了一个新的订阅者 B由于我们告诉ReplaySubject存储两个值因此它将直接向订阅者 B 发出这些最后的值订阅者 B 将打印出这些值。replay$发出另外一个值这时候订阅者 A 和订阅者 B 都接收到值的改变打印出另外一个值
你还可以指定值在ReplaySubject存储的时间我们来看一个例子: 上面代码中发生了那些事情呢
我们创建了ReplaySubject,并指定它只存储最后两个值但是不超过 100ms创建一个订阅者 A我们开始每 200ms 发出一个新的值。订阅者 A 会接收到发出的所有值我们创建一个订阅者 B由于是在 1000ms 后进行订阅。这意味着在开始订阅之前replay 已经发出了 5 个值。在创建ReplaySubject时我们指定最多存储 2 个值并且不能超过 100ms。这意味着在 1000ms 后订阅者 B 开始订阅时由于replay 是 200ms 发出一个值因此订阅者 B 只会接收到 1 个值。
4、AsyncSubject: 只有在Subject完成时订阅者才会收到最后一个值。 可以看作是在Observable完成时发射最后一个值的特殊Subject。 适用于只关心Observable完成时的结果的场景。
const asyncSubject new AsyncSubject();
asyncSubject.subscribe(value console.log(value));
asyncSubject.next(1);
asyncSubject.next(2);
asyncSubject.complete(); // 输出: 2总的来说这些Subject的选择取决于使用场景。BehaviorSubject适用于需要初始值的场景ReplaySubject适用于需要缓存历史值的场景AsyncSubject适用于只关心Observable完成时的结果的场景而普通的Subject则是一个简单的广播机制。
