system.reactive 相关问题

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

等待后,反应程序不会终止

我希望下面的程序能够回显任何按键,直到你按下z,但是当你点击z时它不会终止,并且只会在每次按键时回显。我做错了什么?使用System.Reactive; ...

回答 1 投票 1

从IObservable列表中创建IObservableList

我正在寻找一个实现IObservable的反应对象 >和IList >。就是这样,我希望能够写出:var list = new ...

回答 1 投票 1

ReactiveUI:来自后台线程的UI线程上的Scheudle任务

我需要在后台线程上处理大型数据集,然后在WPF接口的DataGrid控件中显示该数据。数据来自外部工业设备,我提供了...

回答 1 投票 0

在使用RX返回之前填充一些列表

我正在尝试填写一份列表,其中包含有关机场的详细信息。首先,我将获得满足一定条件的机场列表,并获取每个项目的详细信息...

回答 1 投票 0

RX:如何将IObservable绑定到属性(ReactiveUI)

我有一个带有Observable的A类客户端 (Client.Status Stream())。现在我想结合ReactiveX和ReactiveUI。但文档没有提供任何示例如何使用...

回答 1 投票 1

使用一个observable同步另一个observable

我想使用另一个用作时钟的同步观察一个observable,下面举例说明。主要:--------- abc ----------------------------------时钟:-x ----- ----- X ----- X ----- X ----- X -... X

回答 2 投票 2

RX.Net中的主题是否总是有害的?

我正在和一位同事交谈,他向我指出了有关被认为有害的主题的问题。但是,我有两种情况,我有一些似乎不合理的非确定性代码......

回答 4 投票 9

使用Rx,如何在我的Subscribe方法运行时忽略all-except-the-latest值

使用Reactive Extensions,我想忽略来自我的Subscribe方法运行时发生的事件流的消息。即它有时需要我处理消息的时间比时间长......

回答 9 投票 33

在F#中混合使用IObservable和Async

我有一个由库提供的IObservable,它监听来自外部服务的事件:let startObservable():IObservable = failwith“Given”对于每个收到的事件,我想......

回答 2 投票 3

事件限制是什么意思?

今天早上我读了很多关于Rx节流的文章,我对节流感到有些困惑。在本文中,它说“限制强制执行函数的最大次数......

回答 1 投票 0

找不到Akavache GetObjectAsync方法

我已经安装了akavache Nuget软件包(尝试过v5.0和v6.0.0-alpha,我使用的是.NET标准版),但是无法通过Web访问许多示例中提到的GetObjectAsync。 (即使在......

回答 1 投票 1

Rx:具有可变背压缓冲时间的缓冲液

我和Rx玩了一点,但仍然认为自己对世界是新的。我有一个问题,我想知道我是否可以通过Rx解决它。我最初的用例是在C#中,但可能以后想要相同的......

回答 1 投票 2

订阅前运行ToProperty

我有一个ReactiveCommand,它产生一个整数作为输出。公共ReactiveCommand 计算{get;这个命令的最新结果存储在变量中使用...

回答 1 投票 0

如何处理重叠流的反应式扩展?

假设我有一系列这样的:X - X - A - B - C - X - X我对两个事件感兴趣:1-)如果A - B - C顺序发生。 2-)如果B - C顺序发生并且如果A - B - C不发生......

回答 1 投票 0

在订阅回调中结束订阅

代码:subscription = source //最终关闭websocket .Finally(()=> webSocket.CloseAsync(WebSocketCloseStatus.Empty,String.Empty,...

回答 2 投票 0

无效的IObservable转换,运行时异常

我正在创建一个帮助器来过滤流/可观察的特定类型的对象。这是要点:公共接口IGameAction {} //示例动作公共结构OpenDoorAction:IGameAction {} ...

回答 1 投票 3

如何对包含Task.Delay的代码进行单元测试?

如何单元测试具有等待Task.Delay的组件,而不必等待它。例如,public void Retry(){// doSomething(); if(fail)await Task.Delay(5000); ...

回答 6 投票 6

等待TestScheduler

我正在使用TestScheduler来测试和设计我的序列,但是对于下面的代码片段,TestScheduler挂起,而DefaultScheduler工作正常。有可能在某些情况下删除等待......

回答 1 投票 0

使用Observable.SelectMany忽略源集合中除最新项之外的所有项

给定//可观察文件夹中的文件,因为它们是创建IObservable files = GetFilesAsTheyAreCreated();和函数//获取文件的行,因为它们写成IObservable&...

回答 1 投票 1

单侧去抖(Rx)

我想创建一个“单侧去抖动”,其中F事件仅在n的时间跨度没有T事件时传递。关于如何解决这个问题的任何想法?大理石图:在:(T)(F)(T)(F)......

回答 2 投票 0

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