从观察者的角度来看,将Subjectlast()运算符一起使用是否与ReplaySubject(1)相同?

换句话说,在这种情况下:

let s1 = new Subject<any>().pipe(last());
let s2 = new ReplaySubject<any>(1)();


因此,在这种情况下,如果s1s2的序列源相同,那么s1s2的订户将看到相同的值序列吗?

最佳答案

不,他们不会做同样的事情。

last的目的是阻止可观察对象发出任何东西,直到该可观察对象完成为止,这时它立即发出最后一个值。任何想要查看最后一个值的人都必须在出现之前订阅。

ReplaySubject的目的是能够延迟订阅。使用ReplaySubject(1),如果某人在观察对象已经发出一段时间后订阅了该可观察对象,他们将立即重播发出的最后1个事物。

范例1:

let subject = new Subject();
let s1 = subject.pipe(last());
s1.subscribe(val => console.log('first subscription', val));
subject.next(1);
subject.next(2);
subject.next(3);
subject.complete();
s1.subscribe(val => console.log('second subscription', val));


在上面的示例中,您将看到它注销了“第一个订阅3”,并且没有其他内容。

范例2:

let s2 = new ReplaySubject(1);
s2.subscribe(val => console.log('first subscription', val));
s2.next(1);
s2.next(2);
s2.next(3);
s2.complete();
s2.subscribe(val => console.log('second subscription', val));


在示例2中,您将看到它注销了“第一订阅1”,“第一订阅2”,“第一订阅3”,“第二订阅3”

10-06 11:47