以固定或最小间隔处理Rx事件
我有一系列每10-1000毫秒发生的事件。我订阅了这个事件源，但想以固定（或最小）的500毫秒间隔处理它们。 我还想一次只处理一个事件，而不是批量处理（如Buffer(x>1))。 伪代码如下： observable.MinimumInterval(TimeSpan.FromMili...
RX Observable.TakeWhile在每个元素之前检查条件，但我需要在检查后执行条件。
Observable.TakeWhile允许您在条件为真时（使用委托以便我们可以对实际序列对象执行计算）运行序列，但它在每个元素之前检查此条件。我如何执行相同的检查，但是在每个元素之后进行？ 以下代码演示了问题 void RunIt() { List<...
使用Reactive UI订阅层次结构属性更改是否有模式？
假设我有以下视图模型:public class AddressViewModel : ReactiveObject { private string line; public string Line { get { return this.line; ...
如何使用Rx.Next扩展的ForEachAsync与异步操作
我有一段从 SQL 流式传输数据并将其写入另一个存储库的代码。该代码大致如下： using (var cmd = new SqlCommand("select * from MyTable", connection)) { using (var reader = await cmd...
对于Observable，订阅顺序是否保证与通知顺序相同？
我想知道，给定以下RX代码：myObservable.subscribe(obs1) myObservable.subscribe(obs2) ...保证obs1.onNext在obs2.onNext之前被调用 PS：从我的角度来看，编写依赖于订阅顺序的代码是不好的实践，但我很好奇RX文档中...
subscribeOn和observeOn只应由最终订阅者调用吗？
Intro to Rx中的调度和线程一节指出： 使用SubscribeOn和ObserveOn应该只由最终订阅者调用。 它还指出，在UI应用程序中，通常是最终订阅者的表示层应该调用这些方法。 我想知道这个建议是否可靠，因为我在一些情况下发现这不太方便： 首先，我认为展示层不应该决定...
为什么在所有初始订阅者断开连接后，RefCount没有起作用？
请看下面的内容： 考虑以下情况： [Fact] public void foo() { var result = new Subject<bool>(); var startCount = 0; var completionCount = 0; ...
随着可观察项的生成，处理它们
我有一个生成一次性项的IObservable，并且它在其生命周期内可能会生成无限数量的这些项。因此，每次生成新项时，我希望处理最后一项，以便Using运算符不能用于此目的。是否有不同的Rx.NET运算符可以实现此功能？
能否用新的响应式框架替代C#中的传统事件处理方式？
我看到的System.Reactive.dll的所有示例都涉及事件、EventArgs和EventHandlers，我想知道是否有人可以展示一个处理事件通知但不使用这些内容的示例。 例如，在Microsoft的XNA框架中，你有一个叫做Mouse.GetState()的静态方法，它将返回当前...
使用响应式扩展重新排序事件
我正在尝试对来自不同线程的无序事件进行重新排序。是否可以创建一个反应式扩展查询以匹配这些弹珠图：s1 1 2 3 4 s2 1 3 2 4 result 1 2 3 4 并且...s1...