Subject、BehaviorSubject、AsyncSubject ReplaySubject的区别

// Subject 既是 Observable 对象，又是 Observer 对象 
    let s$ = new Subject();    
    let s = s$.asObservable();
    // 大意是BehaviorSubject会发送离订阅最近的上一个值，没有上一个值的时候会发送默认值（若是有的话) 
    let bs$ = new BehaviorSubject<number>(0);    
    let bs = bs$.asObservable();
    // 归纳的讲就是使用AsyncSubject不管发送多少个数据事件，观察者永远只能接受到最后一个数据(完成事件必须调用)。若是发送数据过程当中出现错误，观察者仅仅接受到错误信息。 
    let as$ = new AsyncSubject();    
    let as = as$.asObservable();
    // 该Subject会缓存全部的发射数据，不管观察者什么时候订阅，Subject都会将全部内容发送给订阅者。 
    let rs$ = new ReplaySubject();    
    let rs = rs$.asObservable();
    let i = 0;    
    let time = setInterval(() => {      
        if (i > 5) {        
            bs$.complete();        
            s$.complete();        
            as$.complete();        
            rs$.complete();        
            clearInterval(time);      
        }      
        i++;      
        bs$.next(i);      
        s$.next(i);      
        as$.next(i);      
        rs$.next(i);
        rs.subscribe(res => console.log('ReplaySubject', res)).unsubscribe();      
        as.subscribe(res => console.log('AsyncSubject', res)).unsubscribe();      
        s.subscribe(res => console.log('Subject', res)).unsubscribe();      
        bs.subscribe(res => console.log('BehaviorSubject', res)).unsubscribe();    
    }, 1000);复制代码

执行结果

分析总结-发个博文，总结备忘！

一、Subject 既是 Observable 对象，又是 Observer 对象，只发送订阅后的接收的数据！

二、大意是BehaviorSubject会发送离订阅最近的上一个值，没有上一个值的时候会发送默认值（若是有的话)

三、归纳的讲就是使用AsyncSubject不管发送多少个数据事件，观察者永远只能接受到最后一个数据(完成事件必须调用)。若是发送数据过程当中出现错误，观察者仅仅接受到错误信息

四、该Subject会缓存全部的发射数据，不管观察者什么时候订阅，Subject都会将全部内容发送给订阅者。