标签：system.reactive
-
观察其他观察者看不到的价值 - c#
我有一个观察到的发出独特的价值，例如 var source=Observable.Range(1,100).Publish(); source.Connect(); 我想从例如观察它的价值两个观察者，但每个观察者仅针对其他观察者未看到的值得到通知。 因此，如果第一个观察者包含值10，则第二个观察者永远不会收到有关10值的通知。 更新资料 我选择@Asti的答 […]
-
发生异常时将IObservable <bool>和IObservable <Exception>合并到一个可观察到的OnErrors - c#
我正在尝试创建一个单一的Observable，它的OnNext流来自一个可观察的，哪个OnError流来自另一个可观察的。 之所以这样做，是因为我试图包装一个我控制范围之外的类，并使用事件来传达其状态。它有两个事件，一个指示完成（布尔），另一个指示发生异常。 IObservable<Exception> error = Observable.Fr […]
-
如果第一个为空，则切换到其他IObservable - c#
我正在编写一个函数，用于检索有关主题的新闻并通过IObservable返回值反馈该新闻。 但是，我有几个新闻来源。我不想使用Merge将这些来源合并为一个。相反，我想做的是按优先级排序- 调用我的函数时，将查询第一个新闻源（产生一个表示该源的IObservable）。如果该新闻源的IObservable完成而没有返回任何结果，则查询下一个新闻源。如果第二个来 […]
-
反应性扩展.MaxBy - c#
为什么 var a = Observable.Interval(TimeSpan.FromSeconds(1)) .Publish(); a.Subscribe(o => { Console.WriteLine("Test"); }); a.Connect(); 火，但不是 var a = Observable.Interval(T […]
-
有没有办法监听Reactive Extensions中没有引发的事件？ - c#
我需要在用户开始键入时关闭某些功能，这很简单。当用户停止键入时，我想重新打开该功能。 如果没有反应性扩展，则可以使用timer简单地实现此功能，该功能可将每次最后一次击键时的计时器重置为1 second，并在user stops typing and timer elapses功能打开时将其重置。 有什么方法可以调用以实现与Reactive Extensio […]
-
反应性扩展:使用Rx创建可处理文件的管道 - c#
我有一个包含三个步骤的流程管道： 视频到图像：我有一个视频已转换为静止图像（框架）将帧转换为zip文件：处理完视频中的所有帧后，我应该使用它们创建一个Zip文件。zip文件=>上载到FTP 它涉及两个一次性物品：视频捕获文件和zip文件。 如何使用Rx处理它？我不知道如何开始。 参考方案 您是否必须传递每个步骤中的原始对象。最好将视频捕获文件或zip文 […]
-
*异步方法的IObservable序列 - c#
我有一个源元素Foo的列表，还有一个异步方法GetBoosAsync()将它们转换为类型Boo的元素： public class Foo { public string Value { get; set; } } public class Boo { public string Value { get; set; } } static void Main(s […]
-
如何从长期运行中获得中间结果？ - c#
以下面的类为例，并假定Calculate是一个计算量很大的函数。 class Algorithm { FinalResultObject Calculate() { longPartialCalculation(); //signal to caller that that part is ready of type MidResult1 moreParti […]
-
SelectMany等待和结果排序 - c#
在Deep Dive into Rx SelectMany文章中，作者在最后的注释中提到了以下内容； 注意：为缓解订购问题，SelectMany()随附了一个 重载，它带有签名Func<TSource, int, Task<TResult>>的选择器。 有人可以启发我如何工作吗？ c#大神给出的解决方案 在上述重载的元数据描述中，它表 […]