system.reactive 共享一个订阅（发布）
示例
给定一个IObservable<Offer>的offers从商家购买或以固定价格出售某些类型的项目，我们可以按照如下匹配对买家和卖家的：
var sellers = offers.Where(offer => offer.IsSell).Select(offer => offer.Merchant); var buyers = offers.Where(offer => offer.IsBuy).Select(offer => offer.Merchant); var trades = Observable.Zip(sellers, buyers, (seller, buyer) => new Trade(seller, buyer));
问题在于，每个订阅trades将订阅offers两次。我们可以sellers和buyers共享一个单一订阅offers使用Publish：
var trades = offers.Publish(_offers =>
{
var sellers = _offers.Where(offer => offer.IsSell).Select(offer => offer.User);
var buyers = _offers.Where(offer => offer.IsBuy).Select(offer => offer.User);
return Observable.Zip(sellers, buyers, (seller, buyer) => new Trade(seller, buyer));
});
热门推荐
10 朋友新年祝福语大全 简短
11 新年祝福语简短大方兔年
12 搬新家礼物祝福语简短
13 同学见面花束祝福语简短
14 五一假期祝福语幽默简短
15 离职欢送敬酒祝福语简短
16 对学弟的祝福语简短
17 考老师辞职祝福语简短
18 祝福语驱散霉运的话简短