system.reactive 相关问题

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

如何在C＃中运行时更改IObservable Func谓词

>谓词，位于...

c# system.reactive reactive dynamic-data rx.net

回答 2 投票 1

Rx-跟踪鼠标平移操作

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

reactive-programming system.reactive

回答 1 投票 0

如何在Python的rx（反应性）管道中检索可观察的集合？

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

python system.reactive

回答 1 投票 0

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

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

wpf f# system.reactive

回答 1 投票 0

Rx DotNet-使用线程链接可观察对象

我正在尝试在我的Xamarin移动应用程序中引入Rx，我想在应用程序启动的登录阶段链接一系列的呼叫。 TL; DR;如何依次运行2/3个可观察对象...

c# xamarin reactive-programming system.reactive

回答 1 投票 1

The Observable.Repeat不可阻挡，是错误还是功能？

当源可观察者的通知是同步的时，我注意到Repeat运算符的行为有些奇怪。后续的TakeWhile无法停止产生的可观察对象...

c# system.reactive rx.net

回答 1 投票 0

为什么重复可枚举到可观察转换块

这是出于好奇的教育，出于好奇。请考虑以下代码段：var enumerable = Enumerable.Range（0，5）; var observable = enumerable.ToObservable（）; var enu =可观察...。

c# observable system.reactive enumerable

回答 1 投票 5

Switch（）之后的[StartWith（），初始订阅除外

我有一个IObservable ，每当一个不同的IObservable发出一个值时，就会将Switch（）取出，就像这样：IObservable Invalidated => stateChanged .Select（state => ... ] >>]]] >

c# system.reactive

回答 1 投票 0

为什么IEnumerable.ToObservable这么慢？

我试图一次枚举一个大的IEnumerable，并观察附加了各种运算符（计数，总和，平均值等）的枚举。一种明显的方法是使用...

c# system.reactive rx.net

回答 1 投票 1

默认情况下可观察到的吞咽异常？

我有一个IObservable设置，我试图触发它从“冷”过渡到“热”。但是，通过纯粹的愚蠢运气，我发现IObservable中的某个地方抛出了未处理的异常。 ...

c# system.reactive

回答 1 投票 1

我如何使用system.reactive在每次迭代中使用值的情况下执行do？

为了示例，假设我决定从以下内容开始：var startingSequence = await GetLastSequence（database）;返回Observable.Create （（异步（...

c# system.reactive

回答 2 投票 0

RxSwift |初始化并推送UIViewController闭包

例如，我们有三个UIViewControllers：A，B，C。我们从A推入B。在B中，我们调用一些API：func getProduct（productNumber：String）{someService.rxGetProduct（productNumber：...

ios swift closures system.reactive deinit

回答 1 投票 0

Sport IObservable 单独的IObservable 例外，并且继续正常运行 ] >>

我有一个热的IObservable 可能会引发异常。但是，我想继续。我想我可以使用Retry运算符。但是，如果我还可以听的话，那将是非常不错的...

system.reactive

回答 2 投票 2

我如何从C＃中长期存在的HTTP连接接收实时数据？

我正在尝试处理与之集成的服务器的HTTP长期连接的结果。我希望每个“事件”此服务器返回一行JSON（\ n分隔）...

c# .net system.reactive http-streaming

回答 2 投票 0

突发数据的无功累积

问题：有大量数字值。值以突发方式推送，因此100个值可以彼此非常接近（按时间），例如每5-10毫秒，然后可能会停止一会儿，然后...

reactive-programming system.reactive unirx

回答 1 投票 0

Rx.Net内存泄漏

一个有趣的内存泄漏。有人知道为什么吗？ foreach（Enumerable.Range（0，1_000_000）中的int x。选择（异步i => i））{} GC.Collect（）; Console.WriteLine（GC.GetTotalAllocatedBytes（））; // ...

c# linq system.reactive

回答 1 投票 0

为什么C＃Rx Subscribe（）函数不能与“ async”关键字一起使用？

我有此代码段：static void Main（string [] args）{Observable.Range（1，5）.Subscribe（async x =>等待DoTheThing（x））; Console.WriteLine（“ done”）; }静态异步任务DoTheThing（...

c# asynchronous async-await system.reactive subscribe

回答 1 投票 1

如何有条件地停止可观察对象的定时间隔序列？

下面是每秒运行以依次输出数字的代码：IObservable timestamps = Observable.Interval（TimeSpan.FromSeconds（1））.Timestamp（）.Where（x =＆...

c# conditional-statements observable system.reactive intervals

回答 1 投票 0

System.Reactive在Scheduler.Default和TaskPoolScheduler.Default之间进行选择

我在Scheduler.Default和TaskPoolScheduler.Default之间进行选择时遇到很大的困难。我已经看到它建议TaskPoolScheduler效率更高/最优化，并且肯定具有...

.net-core system.reactive

回答 1 投票 1

IObservable ]的SynchronousBuffer扩展方法 ] 我需要一个不能按时或在特定条件下进行缓冲的Buffer方法。它的行为应类似于此快照方法： Taking a snapshot of ReplaySubject<T> buffer 但是不应该拍摄单个快照，当同步更改发生时，它应该缓冲，并提供IObservable >。我认为应该有一个几乎简单的解决方案作为此Snapshot方法，但我无法直面如何真正解决此问题。（注意：快照方法也可以用于多个主题的查询）这里是一种测试方法： [TestMethod] public async Task SyncBufferTest() { var i1 = new BehaviorSubject<int>(1); var i2 = new BehaviorSubject<int>(4); var sum = i1.CombineLatest(i2, (i1Value, i2Value) => i1Value + i2Value); var listAsync = sum.SynchronousBuffer().Select(buf => buf.Last()).ToList().RunAsync(new CancellationToken()); Action syncChange1 = () => { i1.OnNext(2); i2.OnNext(5); i1.OnNext(7); }; Action syncChange2 = () => { i1.OnNext(1); i2.OnNext(1); }; Action syncChange3 = () => { i1.OnNext(3); i1.OnCompleted(); i2.OnCompleted(); }; Task.Run(syncChange1) .ContinueWith(t => syncChange2()) .ContinueWith(t => syncChange3()); var list = await listAsync; CollectionAssert.AreEqual(new List<int> { 5, 12, 2, 4 }, list.ToList()); } 背景：我正在研究一个以反应性数据层作为应用程序基础的体系结构概念。整个数据层包含主题（作为“交谈”数据层）。在一次交易中，将更改多个这些主题。我在应用程序的较高层中有许多可观察对象，它们是对多个主题的查询。因此，我需要此SynchronousBuffer来处理所有这些查询中所有这些主题的同步更改，以免多次通知。我需要一个不能按时或在特定条件下进行缓冲的Buffer方法。它的行为应类似于以下快照方法：拍摄ReplaySubject 缓冲区的快照，但是应该...

我需要一个不能按时或在特定条件下进行缓冲的Buffer方法。它的行为应类似于以下快照方法：拍摄ReplaySubject 缓冲区的快照，但是应该...

c# system.reactive

回答 2 投票 0

system.reactive 相关问题

最新问题