system.reactive 相关问题

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

Rx 取消和竞争条件

我有一个异步方法,它从 Rx Observable 接收数据并将其写入文件。给这个方法一个cancelToken并在某个随机时间取消它。 这个方法是用await实现的

回答 1 投票 0

C# Rx 取消和竞争条件

我有一个异步方法,它从 Rx Observable 接收数据并将其写入文件。给这个方法一个cancelToken并在某个随机时间取消它。 这个方法是用await实现的

回答 1 投票 0

在响应式扩展中是否有更好的方法来实现这一点?

我想要与 Buffer 类似的行为,除了缓冲仅在接收初始事件时开始并在单个缓冲区后结束。然后重复循环(等待下一个事件再开始...

回答 1 投票 0

如何取消订阅System.Reactive的Subject

我是 System.Reactive 的新手,对主题及其使用方法有些困惑。 我在这里有一个主题的基本实现: 公共类 MessageService :IMessageService { 私人

回答 1 投票 0

使用反应式扩展对事件进行单元测试

我正在使用 .NET (Rx) 反应式扩展将事件公开为 IObservable。我想创建一个单元测试,在其中断言特定事件被触发。这是...的简化版本

回答 4 投票 0

相同的异常抛出两次会导致 WPF 崩溃

我们似乎在 WPF 中遇到了一些带有未处理异常的“有趣”行为。 简而言之,短时间内在调度程序线程上抛出两次相同的异常将绕过

回答 2 投票 0

如何合并同一源的热和冷可观测值,同时有效避免重复?

我有元素来源。它可以被查询,并在添加元素时发布事件。换句话说,我可以从查询结果中生成冷可观察值,并从 ev 中生成热可观察值...

回答 1 投票 0

如何实现自己的合并运算符来正确合并冷可观察值

有谁知道合并运算符是如何实现的?我惊讶地发现 Merge 运算符可以正确合并冷可观察量: var odd = new int[] { 1, 3 }.ToObservable()....

回答 1 投票 0

如何检测没有数据或无流。 Rx.net

我想管理 rx.net 中没有数据或没有流的情况。我只是模拟什么与udp服务有连接。 我正在尝试这样做: 可观察的 。推迟( ()...

回答 1 投票 0

关于多个调用的 IConnectableObservable.Connect 合约

当 IConnectableObservable.Connect 被多次调用时,它的合约应该是什么? 当返回的 IDisposable 被处理时,应该发布 OnCompleted 还是应该...

回答 1 投票 0

使用 Observables 检测点击和双击

我有一个点击事件流,我想从该流中确定用户是否执行了单击或双击。目前我正在尝试通过缓冲 v 来做到这一点...

回答 1 投票 0

使用 RxExtensions 聚合数据流

我有一个学习 Rx 的游戏项目,因为它是我一直想学习并且可能有用的东西。 我似乎无法像 Linq 那样理解它。 所以我有一个数据流并且想...

回答 1 投票 0

如何使用yield返回并行块或Task中Item的集合

我正在寻求有关如何使用yield关键字在并行块或任务块中返回IEnumerable的帮助。 这是伪代码: 公共 IEnumerable> ReadFile( ) ...

回答 2 投票 0

与关闭选择器重叠缓冲区

当用户在屏幕上拖动鼠标光标并单击按钮时,我会发出一系列鼠标事件。我想对这些事件执行成对操作,并且可以执行此操作...

回答 1 投票 0

无法添加对“YourProject”的引用。程序集必须具有“dll”或“exe”扩展名才能被引用

当我尝试在同一解决方案中添加对类库类型项目的引用时,我收到一个消息框,显示: 无法添加对“YourProject”的引用。一个程序集必须有 一个...

回答 3 投票 0

用于模式匹配的反应式扩展运算符

我想订阅流并在观察到特定事件序列时收到通知。 类似于 - 在非常多的伪代码中:.WhenType().ThenType<

回答 1 投票 0

反应式运算符设置超时行为,但仅当返回一定数量的项目时

我有一个场景,其中有来自仪器的可观察测量序列,仅当值发生一定量的变化时才触发测量事件。 底层...

回答 1 投票 0

找不到 Rx Dump() 方法

我在这里以及其他网站上的各种帖子和教程中看到了很多答案,其中 Dump() 方法用于 IObservable 序列。然而,当我尝试使用它时,我得到了...d...

回答 2 投票 0

DynamicData - 如何绑定到分组数据

我正在使用 Roland Pheasant 的动态数据。 动态数据 我想将我的普通 C# 集合转换为 Rx。 来自一个 可观察集合> 动态...

回答 1 投票 0

System.Reactive,一次处理一个 Azure 队列消息

在这个问题上遇到了一点麻烦,希望你们能帮忙...我正在使用 C# System.Reactive。我有一个可观察的,它只是一个从天蓝色的队列获取天蓝色队列消息的间隔...

回答 1 投票 0

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