如何在 silverlight 中获取 IObservable.ToTask 功能

发布于 2024-10-30 04:08:04 字数 693 浏览 2 评论 0原文

在未提供 TPL 的 Silverlight 中，如何实现使用 IObservable ToTask 方法获得的行为？我希望异常能够将结果提升为 IEnumerable，并且能够阻止并等待 Observable 完成。

以下是我使用 ToTask 所做的示例：

int collectionSize = 200;
service.Collection.CreateSampleCollection(size: collectionSize).Wait();
var query = (QuerySource)service.Collection.CollectionTestModel.All();
var queryTask = query.ToTask();
query.Fetch();
var entities = queryTask.Result;
CollectionAssert.AreEquivalent(entities.Select(e => (int)(long)e["Number"]), Enumerable.Range(0, collectionSize));
service.Collection.DeleteTestCollection().Wait();

那么将此代码转换为其他 RX 扩展的简单方法是什么？使用 Run 我必须添加 onNext 和 onError(?) 并且必须在 onNext 中聚合结果。有没有更简单的方法来做到这一点？

原文

How can I achieve the behavior you get with IObservable ToTask method in Silverlight where the TPL is not provided ?
I want exceptions to get promoted up results as IEnumerable and be able to block and wait for Observable to complete.

Here is an example of what I'm doing with ToTask :

int collectionSize = 200;
service.Collection.CreateSampleCollection(size: collectionSize).Wait();
var query = (QuerySource)service.Collection.CollectionTestModel.All();
var queryTask = query.ToTask();
query.Fetch();
var entities = queryTask.Result;
CollectionAssert.AreEquivalent(entities.Select(e => (int)(long)e["Number"]), Enumerable.Range(0, collectionSize));
service.Collection.DeleteTestCollection().Wait();

So what would be a simple way to translate this code in to other RX extensions ?
Using Run I have to add onNext and onError(?) and I have to aggregate the results in onNext. Is there a simpler way to do this ?

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

囚你心 2024-11-06 04:08:04

您可以使用 First() 进行阻塞，直到有可用值为止（同样，Last 也会阻塞）。

如果您需要所有值，可以下载最新的构建 Rx 并使用 .ToArray().First()。

回复收藏 0 原文

随波逐流 2024-11-06 04:08:04

如果您没有最新版本的 Rx，ToList 也很容易编写：

public static List<T> ToList<T>(this IObservable<T> This)
{
    return This.Aggregate(new List<T>(), (acc, x) => {
        acc.Add(x);
        return acc;
    }).First();
}

And if you don't have the latest build of Rx, ToList is easy enough to write anyways:

public static List<T> ToList<T>(this IObservable<T> This)
{
    return This.Aggregate(new List<T>(), (acc, x) => {
        acc.Add(x);
        return acc;
    }).First();
}

回复收藏 0 原文

~没有更多了~