system.reactive 相关问题

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

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

将列表中的属性组合为单个可观察的响应式方法

我们正在努力寻找一种合适的方法来将元素列表中的属性值组合为单个可观察元素。以下是一些示例代码（简化了）：public class Result {...

c# system.reactive reactive

回答 1 投票 0

最新的Reactive Extension（Rx）教程

我对Reactive Extensions非常感兴趣，但是我找不到最新的教程。我从使用.NET的Reactive Extensions治愈异步蓝调开始，但是它已经过时了。我可以...

c# .net system.reactive

回答 4 投票 51

Rx [duplicate]的真实示例

可能重复：反应性扩展的好例子用法我已经使用反应性扩展了一段时间，但主要限于处理/编写用户驱动的...

c# .net asynchronous system.reactive

回答 6 投票 23

可观察的具体实现？

是否有可观察的具体实现？我只想观察一个属性。像这样：public IObservable MyValue {get; } =新的Observable ] >>

c# .net .net-core observable system.reactive

回答 1 投票 0

system.reactive 相关问题

最新问题