system.reactive 相关问题

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

Reactive Extensions Observerable.FromAsync: 如何等到异步操作完成后再进行操作?

在我的应用程序中,我从一个消息总线(rabbit mq,但实际上这并不重要)获取事件。这些事件的处理需要相当长的时间,而且事件是以突发方式产生的。...

回答 1 投票 1

EventBus / PubSub与(反应性扩展)RX在单线程应用程序中的代码清晰度有关

[当前,我正在使用带有Scala(和JavaFX)的EventBus / PubSub体系结构/模式来实现一个简单的便笺组织应用程序(有点像Evernote客户端,并带有一些附加的思维导图...

回答 4 投票 38

可从回调方法中观察到

让我说,我有一个继承传统API的类,并且重写了一个虚拟方法,该方法在发生某些情况时会调用MyClass(),因为这=让somethingObservable:IObservable ... [

回答 1 投票 0

如何在可观察到的反应性扩展中存储先前的有效载荷?

我有一个IObservable boolObservable,发布者的行为就像switch。还有具有某些值的变量currentItem和包含预定义的不可变值的defaultItem。每当'true'...

回答 1 投票 0

Rx DelayOnTrue扩展实现

我正在尝试为C#中的bool值实现油门扩展。该实现应直接传递false值,但在传递true时进行限制。大理石图应为:值每个...

回答 1 投票 0

跟踪是什么触发了对C#中IObservable的更新

我第一次使用IObservable,试图调试一些前一段时间编写的代码。我主要遵循它的操作,但是我遇到的问题是我们有一个方法OnChanged ...

回答 1 投票 0

RX订阅后处理

我有一个包含可观察的热点的类。它进行一些图像转换并收集指标(为简单起见,示例中为int)public class Provider {public IObservable

回答 1 投票 0

被动扩展延迟初始化

相当确定,对于使用SimpleInjector解析的类型在ctor中进行操作是不好的做法。尽管这通常会导致此类类型的某些后期初始化,但...

回答 2 投票 0

如何使用C#Rx实现Redis流

因为我找不到任何不使用循环来获取流内容的实现,所以我开始实现一个流内容,但是我遇到了一些问题,也许你们中的一些人可以将我指向正确的位置...

回答 3 投票 0

如何避免在Rx主题中重复订阅

我有一种下面的方法,其中各种客户端可以简单地订阅该主题。我只想处理某人意外不多次订阅的情况。因此,在订阅I ...

回答 1 投票 0

如何解开嵌套的IObservable或IObservable >

我正在尝试从下面的代码创建IObservable ,但是我似乎找不到找到正确解开事件处理程序值的方法。正在发生的是...

回答 1 投票 0

如何解开嵌套的IObservable

我正在尝试从下面的代码创建IObservable ,但是我似乎找不到找到正确解开事件处理程序值的方法。正在发生的是...

回答 2 投票 0

如何循环观察Rx直到满足条件?

我发现了这个极好的答案,它与我要解决的问题非常相似:等待退出时进程有时会挂起我第一次使用此System.Reactive软件包,虽然...

回答 1 投票 0

使用Rx在一个请求中合并两个变量

我想将company和workFor变量合并为一个流,但是我不知道如何。我尝试使用switchMap,zip,merge和concatMapIterable,但没有任何效果。还是我做错了。。我的...

回答 1 投票 0

使用Rx订阅进度事件,并在完成时仍获得结果

我必须调用属于外部组件的方法。该方法的签名如下所示:IImportedData Import(string fileName,Action progress);此操作...

回答 2 投票 2

ReactiveUI-ReactiveObject的“重置”已更改

我的ViewModel上有一个属性“ CurrentCompany”,该属性本身继承自ReactiveObject并声明为OAPH:private ObservableAsPropertyHelper _currentCompany; ...

回答 1 投票 0


Rx-跟踪鼠标平移操作

我正在实现单击并拖动类型的操作,以在图形应用程序中平移相机。我想跟踪我们是否在另一个流中平移,可以通过...

回答 1 投票 0

如何在Python的rx(反应性)管道中检索可观察的集合?

我正在使用rx来从几个来源创建类似的加载。 rx.from_list(files).pipe(ops.map(lambda file:self._dataflow()),ops.subscribe_on(pool_scheduler)).subscribe(...

回答 1 投票 0

使用反应式扩展时如何管理副作用命令?

模块CounterApp打开系统打开System.Windows打开System.Windows.Controls打开System.Windows.Media打开System.Reactive.Linq打开System.Reactive.Disposables打开FSharp.Control.Reactive /// ...

回答 1 投票 0

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