system.reactive 相关问题

System.Reactive是指.NET的Reactive Extensions,也称为Rx。 Rx为开发人员提供了通用IObservable <T>接口的反应式编程模型,而不是传统的命令式编程模型或严格依赖.NET事件或特定API的其他反应式编程模型。

从多线程数据源更新平滑图表

我们有几个图表显示来自表面EMG传感器的过滤数据。此数据通过TCP接收并使用事件传播。数据包是DataPackets类型,因此已过滤...

回答 2 投票 3

SynchronizationContext和TaskScheduler之间的概念区别是什么

Stephen Toub在博客中写道,SynchronizationContext和TaskScheduler都是代表“调度程序”的抽象,你可以给它一些工作,它决定了何时何地......

回答 3 投票 21

Observable勾选并合并结果时启动任务(使用Rx.NET)

我想知道每次Observable是否可以启动任务,并使用这些任务的结果继续管道。结果的顺序无关紧要。我正在使用C#。 ...

回答 1 投票 0

在Observable()操作后删除文件

我在集合(Dictionary>)上运行了一些可观察的操作,其中字符串是作业名称,List是与该作业名称相关的文件。如果我将List转换为Observable ......

回答 2 投票 0

奥尔良谷物代码中的反应性扩展

https://github.com/dotnet/reactive项目有一个重大更新:v4.0更改Ix Async 4.0与以前的版本有重大变化,因为它是第一个LINQ实现...

回答 1 投票 2

如何返回IObservable 在aws lambda

我想要返回一个IEnumerable 在基于推送的通知中,在AWS lambda函数的使用者的响应主体上流式传输。消费| ---呼叫--------- Object1 ------...

回答 1 投票 0

配置内部订阅合并

!!警告:Rx新手!我们有多个价格Feed。要求是订阅所有这些Feed并且每1秒仅输出一次最新的滴答(节流)公共静态类FeedHandler {...

回答 2 投票 2

从带有DynamicData的api到ObservableCache的数据,定期更新

例如,我有api获取Items列表:Task > GetItemsAsync();我想使用带有ObservableCache的Items 。所以,我创建了IItemsService:...

回答 1 投票 1

倾倒可观察 到一个流

我目前有一个Observable 实际上,这是使用这种方法的源文件的一系列块。它将流“chunkify”为byte []序列。问题是,......

回答 1 投票 -1

101 Rx示例

编辑:感谢wiki的链接,我认为自从它已经开始,它更容易去那里检查。不过这里的问题也很好,所以不在身边的人......

回答 7 投票 38

如果没有连接则调用请求的最佳做法 - 每隔4-5秒重复一次呼叫,直到我们得到响应,使用Rx

例如,我们有一些私有的方法getMobileData(){apiClient.getMobileData().subscribeOn(Schedulers.io())。observeOn(AndroidSchedulers.mainThread())...

回答 2 投票 0

如何在“可重复时间”观察中修复竞争条件?

输入是一个可观察的,每次出现问题时都会产生一个值。作为输出,我想要一个observable,如果问题存在较长时间,它会产生一个值。换句话说,我想“重置”......

回答 1 投票 0

在等待可观察时,异常'序列不包含任何元素'

我使用System.Reactive.Linq扩展方法将observable转换为异步方法中的结果。当我有一个对象引用时,代码正确运行;但是,当我将null传递给...

回答 2 投票 -1

Grpc - 使用rx observable

我试图通过GRPC流公开一个observable。我的简化代码如下所示:public override async Task Feed(请求请求,IServerStreamWriter responseStream,...

回答 3 投票 1

我怎样才能“适应”任务 >到IAsyncEnumerable ?

我正在逐步将Ix.NET引入遗留项目。我有许多返回Task的存储级API >,但我想让它们适应IAsyncEnumerable ...

回答 1 投票 0

将函数转换为Rx

我是Rx世界的新手,我发现很难将下面的代码转换成RX。 foreach(FilterStatusItems中的var filterGridStatusItem){if(filterGridStatusItem.FilerValue.Equals(...

回答 2 投票 0

避免在可观察的管道中进行多次调用

我正在尝试创建一个GetAndFetch方法,该方法首先从缓存中返回数据,然后从Web服务获取并返回数据,最后更新缓存。这样的功能存在于akavache中......

回答 1 投票 0

Rx合并运算符和并行执行

为什么.Merge运算符的行为类似于.Synchronize?我有两个事件流,每个事件在不同的线程中发出值(例如使用Observable.Interval)。使用.Merge之后......

回答 1 投票 0

等待后,反应程序不会终止

我希望下面的程序能够回显任何按键,直到你按下z,但是当你点击z时它不会终止,并且只会在每次按键时回显。我做错了什么?使用System.Reactive; ...

回答 1 投票 1

从IObservable列表中创建IObservableList

我正在寻找一个实现IObservable的反应对象 >和IList >。就是这样,我希望能够写出:var list = new ...

回答 1 投票 1

© www.soinside.com 2019 - 2024. All rights reserved.