system.reactive 相关问题

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

C＃Reactive Extensions-我应该退回一次性产品吗？

我试图了解何时是在传递给Observable.Create的函数中返回一次性对象的好时机，而不仅仅是使用using语句通过作用域处理任何资源。正在返回...

c# reactive-programming system.reactive
回答 1 投票 2

在RxJava中执行每个Concat元素之前如何做？

我正在用Kotlin编写api同步模块。我想向人们展示当前正在下载什么应用，但我对此有疑问。让我向您展示我在做什么的示例代码：private val ...

android kotlin system.reactive
回答 1 投票 0

从同一反应性流中重组元素

我想要实现的目标可以描述如下：我有一个样本流，其中带有时间戳的测量值。这是原始流。我在原始流上应用了过滤器，因此我...

c# system.reactive rx.net
回答 1 投票 1

在一个集合中订阅一个集合的不错的Rx方法

我将描述我的对象模型，然后描述我想做的。这是一个Silverlight应用程序，这些是绑定到UI元素的模型对象。协议包含TradingBranch的集合，...

c# silverlight system.reactive
回答 2 投票 1

是否有可能将IObservable 转换为IAsyncEnumerable ] >> 我有一个可观察的IObservable<T> / ISubject<T>，并想通过使用SignalR将其返回。 SignalR具有异步流的概念，您必须在其中返回IAsyncEnumerable<T>。 如何将IObservable<T>转换为IAsyncEnumerable<T>？ 我有一个可观察的IObservable / ISubject ，并想通过使用SignalR返回它。 SignalR具有异步流的概念，您必须在其中返回IAsyncEnumerable 。 ...

我有一个可观察的IObservable / ISubject ，并想通过使用SignalR返回它。 SignalR具有异步流的概念，您必须在其中返回IAsyncEnumerable 。 ...

c# signalr system.reactive iasyncenumerable
回答 1 投票 1

如何在rx.net中实现我自己的运算符

c# system.reactive rx.net
回答 2 投票 1

调度程序中的通知数量限制

我有一个冷的观察者和一个观察者。两者都很慢，但是观察者比可观察者慢。他们处理许多通知，因此我不想无限制地存储通知。 ...

c# system.reactive
回答 1 投票 1

WhenAnyObservable引发消息“仅常数支持索引表达式。”]

我想观察属性路径：MainViewModel.Project.SelectedDocument.Align Align是ReactiveCommand 的常规属性。 Project和SelectedDocument是常规的...

c# system.reactive reactiveui
回答 1 投票 0

Reactive-如何结合/合并/查找具有两个序列的项目

我正在连接到一个网络服务，该服务为我提供一天的所有价格（没有时间信息）。每个价格结果都有对应的“批量运行”的ID。 “批量运行”具有日期和时间...

c# system.reactive
回答 1 投票 0

WPF / ReactiveUI应用程序中的ReactiveCommand阻止UI线程

wpf system.reactive reactiveui
回答 1 投票 0

当所有可观察到的异步项都完成处理后如何运行Final（）？

为了使UI更具响应性，我正在分批输出项目。这里的问题是在最后一个OutputItems（）完成之前调用OnFinally（）。 IObservable ＆...] >>

c# linq async-await system.reactive
回答 2 投票 1

Rx .NET：ToTask与LastAsync与RunAsync

Reactive Extensions具有以下三种方法：ToTask：返回一个任务，该任务将接收可观察序列产生的最后一个值或异常。 LastAsync：返回...的最后一个元素...

c# system.reactive rx.net
回答 1 投票 2

测量kotlin协程性能

我有阻止的sqs侦听器，它从sqs获取消息，进行一些处理（可能是消息验证或充实），将处理后的消息存储在DB中，从sqs中清除消息。我是...

kotlin system.reactive amazon-sqs kotlin-coroutines
回答 1 投票 0

标定Kotlin协程

我有阻止的sqs侦听器，它从sqs获取消息，进行一些处理（可能是消息验证或充实），将处理后的消息存储在DB中，从sqs中清除消息。我是...

kotlin system.reactive amazon-sqs kotlin-coroutines
回答 1 投票 0

为什么在SelectMany中引发异常后，我的进程仍然有效，而类似的rx运算符中的异常会导致未处理的异常？

这里是一个示例程序，它对控制台输入进行了两次订阅（此处可观察到的源不相关）。在第一个订阅中，它使用Observable.SelectMany；在第二个订阅中，它使用类似的...

.net system.reactive unhandled-exception tpl-dataflow
回答 2 投票 1

在处理下一个查询之前批处理数据库结果

代码在处理最后一个结果集之前执行：var rxQueryTimeOut = pollingPeriodInSeconds + dbQueryTimeoutInSeconds; var scheduler = new EventLoopScheduler（ts => new Thread（ts）{...

c# system.reactive
回答 1 投票 0

为什么以下未处理的异常不会使进程崩溃？

我在Observable.SelectMany中有一个异步选择器，该选择器抛出Exception并与Subscribeless的无参数重载结合在一起。这是一个.net 4.6.1控制台应用程序：类Program {static ...

.net system.reactive unhandled-exception
回答 1 投票 0

延迟功能可动态延迟IObable值

[这个问题与IObservable / Rx有关]工作固定延迟var频率= TimeSpan.FromMinutes（5）; Result.Delay（频率）.Subscribe（i => Debug.WriteLine（“固定延迟后”））;伪-...

c# .net datetime delegates system.reactive
回答 4 投票 0

实体框架：将ChangeTracker转换为可观察到的反应流

我们希望观察所有的Entity Framework ChangeTracker记录，这些记录已被修改，添加或删除。如何使用ChangeTracker并将其转换为Observable？当...

c# .net entity-framework .net-core system.reactive
回答 1 投票 -2

为Net Core中的流类创建可观察的对象

如何为课程创建一个Observable？例如，这里是连续销售的类公共类Product {public int ProductId {get; set;} public string ProductDescription {get; set;} ...

c# .net asp.net-core .net-core system.reactive
回答 1 投票 0
最新问题
© www.soinside.com 2019 - 2024. All rights reserved.