system.reactive 相关问题

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

RX主题如何取消订阅

我有一个返回Subject 的服务，并且消费者正在订阅它。如何取消现有订阅并进行处置？

c# system.reactive

回答 2 投票 5

被动扩展：节气门/样本，间隔不断变化

.net system.reactive

回答 3 投票 7

然后将流与RX合并

concurrency rxjs rx-java rx-java2 system.reactive

回答 3 投票 0

合并两个Observable，但仅当第一个Obs紧随第二个Obs之后

我的目标可能用大理石图最容易解释。我有两个Obsservable，xs和ys。我想返回一个名为rs的Observable。 xs --x --- x --- x --- x ------- x --- x --- x- \ \ \ ...

c# system.reactive

回答 3 投票 3

异步方法中的Rx StartWith不应用起始值

我正在尝试使用StartWith方法将初始值注入到RX流中：public async Task ）Stream（Instrument instrumentDetails）{var initialPrice = await ...

c# system.reactive

回答 1 投票 0

如何在一个订阅中组合“ IObservable IsActive”和“ bool IsEnabled”

具有两个属性，类型为public IObservable IsEnabled {get;组; }和第二个公共布尔IsActive {get; set; }，我想使用System ....]将两个属性合并为一个。...

c# reactive-programming system.reactive rx.net

回答 1 投票 1

向RX流/ IObservable添加初始值

我有一种方法将经过过滤的RX流作为Iobservable返回：public IObservable LiveRates（NegotiationDetails谈判）{return _ratesObserver.Stream .Where（o ...

c# system.reactive

回答 1 投票 0

GroupJoin，其中一个窗口在流完成时结束

我有两个数据源，它们正在从单独的线程中转储数据。我正在尝试通过密钥将两个来源都加入。我可以使用GroupJoin做到这一点。我必须使用Observable.Never，这样窗口...

c# system.reactive rx.net

回答 1 投票 0

Rx.Net忽略某些例外，但处理其余例外

使用Catch运算符很容易处理一组特定的异常。我们如何才能忽略某些异常，而在Catch块中处理其余的异常呢？例如，我想让...

system.reactive

回答 1 投票 1

是否有一个Rx.Net运算符告诉已订阅观察者的数量？

如果要正确地将观察者分配给长期运行的服务（暴露IObservable的服务），我将尝试调试。我想知道是否有运算符或我们可以创建的东西...

system.reactive

回答 1 投票 0

订阅多个Observable并在同一线程上得到通知

foreach（...）{Observable.FromAsync（GetData（）/ *一个异步函数（）* /）.DoWhile（（）=> true）.Subscribe（data => {DoSomething（）; //我想要我所有的Subscribe（）...

c# observable system.reactive

回答 1 投票 1

正确地结束可观察流的错误方式

我有几种返回IObservable的方法。在所有情况下，我都将建立一个查询，该查询将导致返回的observable完成。通常，我一直在使用TakeUntil扩展方法。 ...

c# system.reactive

回答 1 投票 0

。NET，每分钟（每分钟）发生一次事件。计时器是最好的选择吗？

我想使用C＃在Windows窗体应用程序中每分钟（按时）每分钟做一些事情。我只是想知道什么是最好的方法？我可以使用计时器并将其间隔设置为60000，...

c# timer system.reactive

回答 15 投票 39

Flutter-继续收听页面更改时的流

我的情况是这样的：BottomNavigationBar，其中一个页面包含一个项目列表（“ listPage”），另一个页面是单个项目（“ itemPage”）。两个页面都可以导航到与...

flutter navigation system.reactive

回答 1 投票 0

按组在单独的线程中运行处理

我正在尝试在我的Kafka用户中使用Rx。公共静态事件EventHandler > GenericEvent;然后我有以下代码var observable = Observable ....

c# asynchronous async-await system.reactive rx.net

回答 1 投票 0

如何抑制可观察到的条件变为真

我的应用程序中有一个集合视图，当有新内容或删除内容时，它将以动画刷新。但是，我不希望用户滚动时刷新它，因为它会导致...

ios swift system.reactive rx-swift rx-cocoa

回答 1 投票 0

rx.net合并重置流

我们有一个正在运行的服务，该服务处理从系统x到系统y的消息。它基本上看起来如下所示：aSystem.Messages.Subscribe（message => {试试{ProcessMessage（message）;} ...

c# system.reactive rx.net

回答 1 投票 1

Rx缓冲区运行一次并完成

我喜欢收集流的第一个值3秒钟，并将它们连接到相同数据类型的另一个流。第一个Observable是一个单独的，已完成的数据块，应在...

c# reactive-programming system.reactive reactiveui

回答 1 投票 0

在Rx中实现滑动窗口的麻烦

我为响应式扩展创建了SlidingWindow（）运算符，因为我想轻松监视滚动平均值等情况。作为一个简单的示例，我想订阅以听取鼠标事件，但是...

system.reactive

回答 4 投票 10

如何观察字符串值的周期性变化？

我们有一个字符串Observable。如果更改，则它将发出新值，并且数据将不进行任何更新。观察者应每秒观察一次String值。我尝试这样做，但是...

android rx-java2 system.reactive

回答 1 投票 0

system.reactive 相关问题

最新问题