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 妈妈生日祝福语简短励志