windows-phone-8 – Rx 2.1：如何在Dispatcher上正确订阅和观察

发布时间：2020-12-14 02:05:01 所属栏目：Windows 来源：网络整理

导读：首先,我使用最新的Rx,即2.1.据我所知,当Rx变为2时,很多事情都发生了变化,所以我真的很期待收到最新的答案.提前致谢. 我正在为Rx实现一个经典任务：观察TextBox的文本(确切地说是来自WPToolkit的AutoCompleteBox),以便向用户提供建议列表.建议来自网络,我想使

首先,我使用最新的Rx,即2.1.据我所知,当Rx变为2时,很多事情都发生了变化,所以我真的很期待收到最新的答案.提前致谢.

我正在为Rx实现一个经典任务：观察TextBox的文本(确切地说是来自WPToolkit的AutoCompleteBox),以便向用户提供建议列表.建议来自网络,我想使用这些普通的Rx好东西,如Throttle,DistinctUntilChanged等.

我也在使用最近发布的适用于Windows Phone 8的便携式HttpClient,因为它提供了基于任务的异步API,这很不错.

我遇到的问题是在读取’AutoCompleteBox`的Text值时的跨线程访问.这是代码：

var http = new HttpClient();
var searchFunc = Observable.FromAsync<HttpResponseMessage>(() => 
            http.GetAsync(FormatUrl(SEARCH_URL,"DE",new GeoCoordinate(51,13),searchBox.Text /* <-- causes exception */,10,"")));

var uithread = new SynchronizationContextScheduler(SynchronizationContext.Current);
var textChange = Observable.FromEventPattern<RoutedEventArgs>(searchBox,"TextChanged")                             
        .Throttle(TimeSpan.FromMilliseconds(800))
        .DistinctUntilChanged()     
        .SubscribeOn(uithread)           
        .SelectMany(searchFunc)                
        .Select(async (resp) => SearchResultsParser.ParseSearchResults(await resp.Content.ReadAsStreamAsync(),13)))
        .Select(async (results) => searchBox.ItemsSource = await results)
        .ObserveOn(uithread)
        .Subscribe();

执行searchFunc时会发生异常.我从VS看到它在Worker Thread上执行,尽管我使用了SubscribeOn.

这是使用SynchronizationContextScheduler的示例,但我也尝试了SubscribeOnDispatcher,结果相同.看起来我遗漏了一些重要的东西,或者Observable.FromAsync.你能不能指出我的错误？

解决方法

SubscribeOn几乎不是你想要的 – 你可能认为它意味着“我的订阅方法运行的地方”,但它实际上意味着“IDisposable(和处理)的实际连线运行” – ObserveOn相当于“这就是我的地方”希望我的实际订阅代码执行“

参考：Observable.SubscribeOn and Observable.ObserveOn

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!