rx.net

0热度

1回答

这是很傻，但我似乎无法找到包含TestScheduler 的.NET RX NuGet包请点我在正确的方向。

3热度

1回答

RxJS/Rx.Net Observable-subscribe vs async-await

我最近开始研究Reactive Extensions，主要是使用Angular 2的客户端的可观察性.Rex的observables和dotnet的async-await的概念似乎非常相似。是否有任何具体的例子，其中一个适用而另一个不适用。如果没有，微软推出Rx.Net的原因是否有其他原因，因为观察者站在反应扩展的核心位置。任何链接或实时示例就足够了。我正在寻找差异线程/性能明智。

1热度

1回答

在Rx.NET中使用树/ ReactiveUI

如何观察树的任何子层的属性更改？考虑例如具有属性Name和ChildNodes的属性TreeNode。如何观察Name任何子级的变化TreeNode？的使用可能是这个样子： rootNode.FlattenTreeToObservable(x => x.ChildNodes) .WhenAnyValue(x => x.Name) .Subscribe(...) 树节

3热度

1回答

RX.Net：使用重试但记录任何异常

我是RX的新手，一直在研究错误处理和Retry的使用;我有以下内容（是的，我知道这不是一个'真正的'单元测试，但它让我可以摆弄！），并想知道如何去保持重试但能够记录任何异常？ [Test] public void Test() { var scheduler = new TestScheduler(); var source = scheduler.C

4热度

3回答

如何使用Rx.Nex扩展ForEachAsync与异步动作

我有代码从SQL流下来的数据，并将其写入不同的商店。代码大致是这样的： using (var cmd = new SqlCommand("select * from MyTable", connection)) { using (var reader = await cmd.ExecuteReaderAsync()) { var list = new List<M

0热度

1回答

如何单元测试Rx.Net的foreach订阅

所有消息应发布到消息总线： upstream.Get().ForEachAsync(async e => await _bus.Publish(e, cancellationToken)); 我想单元测试来验证publish方法被调用正确： [Theory, AutoMoqData] public void Publish_ShouldPublishAllDataSources(

1热度

2回答

React Native，Rx.Net和RxSwift：共同性

我使用RxSwift作为其他人开始的项目的一部分。想要了解更多关于ReactiveX的理论，我碰到了React Native和Rx.Net。我想确保我的理解正确如下：阵营本地是一个Java脚本库，允许开发者构建原生用户界面。该库将Javascript代码转换为本地移动代码。 RxSwift旨在实现Rx.Net的概念，但不同的是，并没有直接联系阵营本地。它们的共同之处在于它们都实现了概念Rea

2热度

1回答

从顶部排出IObservable

我想要消耗一个可随时填充的IObservable。我有这样的扩展方法： public static IObservable<TOut> Drain<TSource, TOut>(this IObservable<TSource> source, Func<TSource, IObservable<TOut>> selector) { return Observable.D

1热度

1回答

如何在Rx.NET中使用NHibernate？

我正在浏览博客和reactivex.net书籍，但我很难看到如何从NHibernate查询创建可观察的流。在RxJava中，我会使用Observable.fromCallable - 或者甚至不是最好的方法。我知道我需要从查询的结果中打开一个无状态的流，但是如何做到这一点的语法不见了。从NHibernate查询创建Observable流的语法是什么？另外，如果不同，如何发出坚持？谢谢！

2热度

2回答

的Rx .NET - 力缓冲发出

我想用Rx缓冲器的功能： var source = new Subject<Price>(); var buffer = source .Buffer(TimeSpan.FromSeconds(30), 5) .Where(p => p.Any()); 这意味着EMIT（发布给用户）时，缓冲区达到5秒或30秒的大小自上次EMIT已经发生了。但我需要能够按需发射 - 例如