system.reactive 相关问题

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

RX 操作员使用先前值进行扫描,信号源自值本身

假设您有一个 IObservable 类型的可观察源源。我正在寻找一个转换函数 IObservable 倒计时(IObservable 源) { // 如何?有事我...

回答 1 投票 0

一个 Rx 可观察对象将充当 ReplaySubject,但仅适用于第一个订阅者?

编写类似于 ReplaySubject 的 Rx observable 的优雅方式是什么,但只为第一个订阅者发出一次累积序列(当该订阅者连接时...

回答 2 投票 0

使用 DynamicData 创建 ViewModel 的派生集合,该集合更新现有项目,而不是在源项目更改时创建新项目

例如,我有一些可观察的集合,它指示对象的状态(我通过 REST API 定期获取它)。 用户类 { int Id { 得到; } 字符串名称 { 获取; } 圣...

回答 1 投票 0

获取 IObservable 中的前一个元素,无需重新评估序列

在 IObservable 序列中(在 .NET 的响应式扩展中),我想获取先前和当前元素的值,以便可以比较它们。我在网上找到了一个类似于下面的例子...

回答 6 投票 0

什么会导致BehaviorSubject报告另一个不相关的可观察量的未处理异常?

上下文 我正在调查一个复杂的问题,由于某种原因,BehaviorSubject 向观察者发出错误。 即使没有人真正与该可观察的交互,这种情况也会发生。 唯一的

回答 1 投票 0

Rx.NET 缓冲区在取消时发出所有项目

我正在以最简单的方式使用 Rx.NET 库及其方法 Buffer,例如: observable.Buffer(TimeSpan.FromSeconds(5), 10); 除了激活取消令牌的情况外,它的效果很好。 ...

回答 1 投票 0

Save() 操作的 RX 实现,如果自上次执行以来已经过了 2 秒,则该操作将立即运行,或者延迟到 2 秒过去了

var i = 0; var saveSource = Observable.Interval(TimeSpan.FromMilliseconds(200)).Select(x => i++); varthrottledClicks=saveSource .Throttle(TimeSpan.FromMilliseconds(2000)) // 节流...

回答 1 投票 0

Rx - 一次只允许 n 个并行操作的调度程序

我正在尝试编写一个允许有限并发的调度程序。这是我写的。 公共类 ThreeAtATimeScheduler :IScheduler { 私有只读 SemaphoreSlim _semaphore = 新

回答 1 投票 0

Observable.Create:CancellationToken 不会转换为 IsCancellationRequested

采用这个小脚本(在 LINQPad 中设计,但应该在任何地方运行): 无效主() { Task.Run(() => Worker()).Wait(); } 异步任务工作者() { 如果(SynchronizationContext.Current!= nu...

回答 3 投票 0

使用 TcpClient 和响应式扩展从 Stream 读取连续字节流

考虑以下代码: 内部课程计划 { 私有静态无效主(字符串[] args) { var client = new TcpClient(); client.ConnectAsync("localhost", 7105).Wait();...

回答 2 投票 0

将流转换为可观察的

我尝试过这个,但似乎存在并发问题。 我不完全明白出了什么问题。 公共静态 IObservable ToObservable(此 Stream 流,int bufferSize = 4096) ...

回答 1 投票 0

何时使用 Observable.FromEventPattern 而不是 Observable.FromEvent?

我们有一个客户端呼叫 TIBCO EMS 队列,并正在连接事件,如下所示: var msgConsumer = _session.CreateConsumer(responseQueue); var 响应 = 可观察的 .FromEvent<

回答 3 投票 0

如何使异步等待响应式扩展 onNext、onError、onCompleted 委托

我创建了以下扩展,我可以在其中使 IObservable.Subscribe 可等待,但包装整个订阅。 当前 C# 异步编程和下面的代码中的一个大问题...

回答 1 投票 0

无法加载文件或程序集“System.Reactive,版本=1.0.0.0

我收到此警告,但找不到对上述程序集的显式引用。 无法加载文件或程序集“System.Reactive,版本=1.0.0.0, 文化=中立,PublicKeyToken=1b331ac6720247...

回答 3 投票 0

RX.net 主题线程对于订阅者来说安全吗?

我很难找到信息,因为谷歌给出了有关同时将数据推送到主题的安全性的结果,这不是我的用例,我有一个专用线程(运行 infin...

回答 1 投票 0

使用 RxJS 模拟命令队列和撤消堆栈

我正在尝试使用 RxJS 复制此演示。该演示是一个小型应用程序,用户可以在其中控制机器人。机器人可以向前或向后移动、向左或向右旋转、拾取或拖动...

回答 3 投票 0

使用 DynamicData 递归地观察子级的变化

我正在为 AvaloniaUI 创建一个完全通用的文件浏览器。它有一个显示文件夹树的视图,您可以通过展开每个目录来导航。 我的目标是让这个视图足够灵活

回答 1 投票 0

在 MAUI 切换之前从代码库中重构反应式 Rx 扩展

所有,我希望删除 System.Reactive 附带的所有 Observable 扩展方法,因为我们正在将当前代码库从 XF 迁移到 MAUI,并且我们有 XF 代码应用程序使用一些...

回答 1 投票 0


使用反应式订阅时如何缓存结果?

在 Blazor 服务器端应用程序中,我有一个组件,基本上是邮政编码的下拉列表。我使用 Reactive 来调用端点,该端点通过搜索条件查找匹配的邮政编码。 我

回答 0 投票 0

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