如何实现“处理剩余”使用反应式扩展的观察者
我有一个 IObservable 和几个根据某些条件处理字符串的观察者： observable.Subscribe(s => { if (s.StartsWith("a")) {...} }); observable.Subscrib…
如何让线程等待，直到变量达到 .NET/Csharp 中的一组值之一
我编写了一个类，该类具有 TProperty 类型的属性和 Action 类型的事件，每当该属性发生更改时就会触发该事件。 TProperty 通常是枚举类型，但这并不重…
异步重复从流中读取？
如何构造以下代码，以便可以分块读取所有流。 目前它不断返回相同的数据。不能前进。 public static IObservable AsyncRead(this Stream stream, int …
如何不断重试反应式方法直到成功？
这是我的 WebClient 异步下载反应式扩展。 一次又一次调用“DownloadStringAsync”直到操作成功的最佳方法是什么？ 像这样但以反应方式： while (true…
使用 Rx 框架立即启动任务，然后按时间间隔启动
我试图立即运行我的任务，然后按时间间隔运行它。 我写了以下内容： var syncMailObservable = Observable.Interval(TimeSpan.FromSeconds(15)); sync…
反应式扩展 - 返回相同的可观察值还是创建新的？
我正在尝试使用 Rx 设计服务层抽象。我已使用 FromAsyncPattern 封装了所有 Web 服务调用。我将有多个 ViewModel 订阅这些可观察量，有些可以有多个订…
记录线程何时等待到达锁定语句
当线程到达 a 时，是否有一种快速方法来记录线程正在等待锁 lock(x) { //do work on a collection } ？ 如果线程 1 到达锁，并且块中没有其他线程，则…
反应性可观察订阅处置
如果我有权访问一个我知道只会返回一项的 IObservable，这是否有效？它是最佳使用模式吗？ IDisposable disposable = null; disposable = myObservabl…
在同一 IObservable 订阅内访问 IObservable
这是我尝试使用响应式扩展执行的简单示例，但它不起作用 Add 在这个简单示例中不起作用 public static void Main(string[] args) { var list = new Li…
使用 Web 客户端接收参数异常
我正在使用反应式扩展，以便使用 Windows Phone 上的 WebClient 轻松下载网页。 当我运行以下代码时，我在 Subscribe 调用中收到 ArgumentExceptoin。…
转换 IObservable将不规则长度字节数组转换为 IObservable具有规则长度的数组
我有一个 IObservable，它在字节数组中提供了不确定的字节数。我想知道如何从那里返回一个 IObservable，每个字节数组中都有一定数量的字节。假设我们…
反应式扩展是否支持滚动缓冲区？
我正在使用反应式扩展将数据整理到 100 毫秒的缓冲区中： this.subscription = this.dataService .Where(x => !string.Equals("FOO", x.Key.Source)) …
使用冷 observable 处理 OnCompleted
在 Rx 中，以下代码执行以下操作：似乎没有调用我的 OnCompleted 操作？ 没有“序列完成” static void Main(string[] args) { var list = new List {…
