我一直在试图围绕.NET的Reactive Extensions来解决这个问题,但已经有一个概念性的墙：我无法解释为什么IObservable.First()阻塞.
我有一些示例代码看起来有点像这样：
var a = new ListItem(a);
var b = new ListItem(b);
var c = new ListItem(c);
var d = new ListItem(d);
var observableList = new List<ListItem> { a,b,c,d }.ToObservable();
var itemA = observableList.First();
// Never reached
Assert.AreEqual(expectedFoo,itemA.Foo);
我期待发生的是因为itemA在一定程度上等于a,并且能够访问其成员等等.而是发生的事情就是永远不会达到First()块和Assert.AreEqual().
现在,我知道足够知道当使用Rx时,代码应该将订阅()到IObservables,所以很可能我在这里做错了.但是,根据各种方法签名,不可能执行以下操作之一：
observableList.First().Subscribe(item => Assert.AreEqual(expectedFoo,item));
要么
observableList.Subscribe(SomeMethod).First() // This doesn't even make sense,right?
我失踪了什么
解决方法
First()返回一个T,而不是一个Observable< T>,所以它必须被阻止.
一个非阻塞形式是xs.Take(1)
