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

https://www.jianshu.com/p/def6965b0475