我想创建一个可观察的wcf调用包装,并创建为波纹管。可观察的订阅未达到完成
的方法是这样的,
private IObservable<List<string>> Search(string searchTerm)
{
return Observable.Create<List<string>>(o =>
{
var searchClient = new SearchServiceClient();
var s = Observable
.FromEventPattern<SearchCompletedEventArgs>(searchClient, "SearchCompleted");
var subscription = s.Subscribe(
r =>
{
if (r.EventArgs.Error == null)
o.OnNext(r.EventArgs.Result);
else
{
o.OnError(r.EventArgs.Error);
}
},
e =>
{
o.OnError(e);
},
() =>
{
o.OnCompleted();
});
searchClient.SearchAsync(searchTerm);
return subscription;
});
}
和方法调用,
Search("reactive").Subscribe(
r =>
{
MessageBox.Show("Result");
},
e =>
{
MessageBox.Show(e.ToString());
},
() =>
{
MessageBox.Show("Completed");
});
但它永远不会伸手完成块。你能建议我要去哪里吗?
@Edited 26日
感谢斯托Vučetin,Rarous和李·坎贝尔。我已经测试了所有三个建议,都在工作。但我喜欢Petar的方法使单行代码成为可能。即使它看起来Observable.FromAsyncPatterns被depricated。
我认为最新的位使得FromAsyncPatterns过时了。 – 2013-04-30 00:22:32
我明白了,我仍然瞄准.net 4.0。 – 2013-04-30 03:59:32