奥尔良粒子代码中的响应式扩展

Question

在 https://github.com/dotnet/reactive 项目中有一个重大更新:

v4.0 变更

Ix Async 4.0 与先前版本存在重大变更，因为它是第一个支持新的 C# 8 异步流特性的 LINQ 实现。这意味着对于 .NET Standard 2.1 和 .NET Core 3 的目标，我们使用内置的 IAsyncEnumerable 接口及其相关接口。在其他平台上，我们提供了实现，所以您可以像预期的那样使用 await foreach 并创建异步迭代器。类型将在平台提供时统一到系统类型。

这里有很多重大变更，完整的变更说明即将发布。

这个库能否在 Orleans 代码中用于处理 grains 中的流？我知道 RX 使用自己的调度程序来运行观察者和订阅（例如 ObserveOn() 和 SubscribeOn()），我想知道是否会与 Orleans 自己的调度程序冲突，或者是否有一种方法让 RX 尊重或利用 Orleans 的任务运行器通过将其传递给上述方法。

- Milogrim

Answer 1

根据GitHub问题#315的最新更新，Orleans不支持Rx.NET。理论上应该可以工作，建议考虑使用类似以下的内容：

var rxScheduler = new TaskPoolScheduler(new TaskFactory(RuntimeContext.Current));

我在Gitter 频道的聊天记录中也没有找到任何有用的信息。

- seniorquico