PublishSubject

//创建一个PublishSubject      

let subject = PublishSubject<String>()      

 //由于当前没有任何订阅者,所以这条信息不会输出到控制台        subject.onNext("111")

//第1次订阅subject       

subject.subscribe(onNext: { string in           

print("第1次订阅:", string)       

}, onCompleted:{         

  print("第1次订阅:onCompleted")   

    }).disposed(by: disposeBag)           

//当前有1个订阅,则该信息会输出到控制台

subject.onNext("222")               

//第2次订阅subject       

subject.subscribe(onNext: { string in           

print("第2次订阅:", string)       

}, onCompleted:{           

print("第2次订阅:onCompleted")       

}).disposed(by: disposeBag)               

//当前有2个订阅,则该信息会输出到控制台       

subject.onNext("333")               

//让subject结束       

subject.onCompleted()               

//subject完成后不会发出.next事件了。       

subject.onNext("444")   

//subject完成后它的所有订阅(包括结束后的订阅),都能收到subject的.completed事件,completed后的onNext就不在执行了。        

subject.subscribe(onNext: { string in           

print("第3次订阅:", string)       

}, onCompleted:{           

print("第3次订阅:onCompleted")        }).disposed(by: disposeBag)   

subject.onNext("555")

输出:

第1次订阅: 222

第1次订阅: 333

第2次订阅: 333

第1次订阅:onCompleted

第2次订阅:onCompleted

第3次订阅:onCompleted

//www.greatytc.com/p/def6965b0475







最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。