system.reactive 相关问题

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

反应式扩展连接中的非相交 LeftDurationSelector

我想创建一个可观察量，当右侧可观察量发出一个值并获取最后一个左侧可观察值时，即发出一个可观察量，即，如下面的弹珠图所示（取自

c# system.reactive

回答 1 投票 0

.NET Rx C# Observable.FromEventPattern 不运行 OnCompleted

我不明白为什么下面的代码无法运行OnCompleted，任何人都可以帮助我，谢谢。基本上我所做的是每次按下一个键，我都会触发一个事件并进行转换...

c# observable reactive-programming system.reactive observer-pattern

回答 1 投票 0

Observable.Using 和异步流获取损坏的数据

我有一个流，其目标是计算一组 .zip 文件中内容的简单“校验和”。为此，我设置了一个可观察值：获取给定文件夹中的所有文件读取

c# .net reactive-programming system.reactive c#-ziparchive

回答 2 投票 0

reactive 和 leafletProxy，在创建 leaflet 应用程序时观察 Rshiny 中的问题

使用if语句、observe和leafletProxy的形式，但我似乎无法让它工作。我有两个独立的数据库，其中一个是 PLOT，另一个是 ISTANBUL_OIM。情节很长。和纬度。

shiny leaflet system.reactive reactive

回答 1 投票 0

(Rx.Net) 缓存数据直到 IObserver 订阅

我有一个热门的 Observable (Rx.Net)，当它检测到设备连接到 PC 时，它就会勾选。我有一个处理这些设备显示的视图。不幸的是，视图可能不会显示，直到...

system.reactive

回答 3 投票 0

如果可观察量生成太多值太快，有没有办法取消和替换它？

我有一个以可变速度生成值的 Observable。为了不被值淹没，我添加了三秒的节流，因此只有在没有发布更多值的情况下我才会获得一个值...

c# observable reactive-programming system.reactive

回答 1 投票 0

`ReplayWhere`可连接可观察

我正在创建一个可观察的对象，它将重放符合条件的最新消息，同时让其他消息通过，但我正在努力使其与当前的 API surf 一起工作...

c# system.reactive

回答 1 投票 0

RX 与像rabbitmq 或zeromq 这样的消息队列？ [已关闭]

我对这些高级并发范例相当陌生，并且我已经开始使用 scala RX 绑定。所以我想了解 RX 与 RabbitMQ 或 ZeroMQ 等消息队列有何不同？该...

rabbitmq system.reactive zeromq reactive-programming

回答 2 投票 0

UniRx 没有 Observable.Generate() 方法

.NET Reactive Extensions 有一个巧妙的方法来使用 corecursion 生成序列，称为 Observable.Generate。我在 UniRx 中找不到该方法的等效项（Unity Reactive Extensi...

c# unity-game-engine system.reactive unirx

回答 3 投票 0

可从 Func 委托观察

是否有方法或库函数可以接受 Func 并通过调用它返回 IObservable？功能应该可能等于公共 IObservable 创建...

c# observable system.reactive reactive observer-pattern

回答 1 投票 0

如何从IObservable中拉取

假设端点A有一个Subject，端点B有一个IObservable。端点 A 使用 OnNext() 发送 T 的一个对象，并且从不调用 OnComplete()。我没有缺点...

c# observable task-parallel-library system.reactive reactive

回答 2 投票 0

响应式的“缓冲直至安静”行为？

我的问题有点像 Nagle 算法旨在解决的问题，但又不完全一样。我想要的是将 IObservable 中的 OnNext 通知缓冲到

c# system.reactive reactive-programming

回答 4 投票 0

C# 可从 Func 委托观察

是否有方法或库函数可以接受 Func 并通过调用它返回 IObservable？功能应该可能等于公共无效创建（Func＆...

c# observable system.reactive reactive observer-pattern

回答 1 投票 0

Rx.NET 缓冲区在报价聚合时存在延迟问题

我正在使用反应式库基于符号报价（外汇和差价合约）进行 1 秒柱聚合到目前为止，IAsyncEnumerable 扩展还没有成功，所以我决定用 Push 代替 Pull

window buffer system.reactive

回答 2 投票 0

Boolean一次性使用指南

作为一般编码指南，何时应该在反应式扩展中使用 BooleanDisposable ？来源： https://github.com/dotnet/reactive/blob/main/Rx.NET/Source/src/System.Reactive/Disposables/

c# .net system.reactive

回答 2 投票 0

如何在 RXNet (C#) 中实现可观察流的 .Debounce() / .DebounceDistinct() 扩展方法？

基本上就是主题所说的。我找不到任何现成的 .Debounce() 扩展方法（类似于 Throttle() 开箱即用的方式）。以下是一个粗略且可能有错误的我...

c# .net reactive-programming system.reactive rx.net

回答 1 投票 0

如何在 RXNet (C#) 中实现可观察流的 .Debounce() 扩展方法？

基本上就是主题所说的。我找不到任何现成的 .Debounce() 扩展方法（类似于 Throttle() 开箱即用的方式）。我提供了我想到的 .Debounce() 实现...

c# .net reactive-programming system.reactive rxnet

回答 1 投票 0

如何在 onNext 之前等待订阅者完成？

我对反应式编程非常陌生，并且我陷入了困境。我尝试实现，如果我的集合已达到一定数量的元素或已达到一定时间，我需要触发某种方法。普...

c# .net .net-6.0 reactive-programming system.reactive

回答 1 投票 0

IAsyncEnumerable 转换为 IObservable（和任务）未启动

我的BackgroundService中有以下代码：公共异步任务 ExecuteAsync(CancellationToken CancellationToken) { 等待 GetElements(cancellationToken) .ToObservable() .Bu...

c# observable system.reactive rx.net iasyncenumerable

回答 1 投票 0

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

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

c# system.reactive

回答 1 投票 0

system.reactive 相关问题

最新问题