rxjs

import {Subject,BehaviorSubject,ReplaySubject,AsyncSubject} from 'rxjs'
const subject$ = new Subject()
/* 上面的不会被订阅到 */
subject$.next(1)
// Subject会按顺序订阅，从开始订阅，后面发布的内容都会被订阅（只能获取到订阅后的内容）
subject$.subscribe((value)=>{
    console.log(`订阅者A：${value}`);  
})
subject$.next(22)
subject$.next(23)
subject$.next(4)


/* 
BehaviorSubject的特点是把最新的值发布给订阅者,可以获取到最后发布的内容（可以获取到订阅之前的内容）
*/
const behavior$ = new BehaviorSubject('a')
behavior$.next('bbb')

behavior$.subscribe((value)=>{
    console.log(`订阅者A_behavior：${value}`);  
})
behavior$.next('b')
behavior$.next('c')

/* 
第一个参数 bufferSize指定了缓存的大小，默认为 Infinity，即缓存所有发出的值，是一个「空间限制」。
第二个参数 windowTime，指定缓存的「时间限制」，默认为 Infinity，即不限制值的失效时间
*/
const replay$ = new ReplaySubject(1)
replay$.subscribe(value=>{
    console.log(`订阅者replay：${value}`);
    
})
replay$.next(1)
replay$.next(2)
replay$.next(3)
replay$.next(3345)
replay$.subscribe(value=>{
    console.log(`订阅者replay_2：${value}`);
    
})


/* 

*/
const async$ = new AsyncSubject()
async$.subscribe(value=>{
    console.log(`订阅者async：${value}`);
    
})
async$.next('11')
async$.next('22')
async$.next('33')
async$.subscribe(value=>{
    console.log(`订阅者async_b：${value}`);
    
})

async$.complete()