rx.net

0熱度

1回答

的NuGet包.netcore TestScheduler

這是很傻，但我似乎無法找到包含TestScheduler 的.NET RX NuGet包請點我在正確的方向。

c# .net rx.net 2017-09-01

---

3熱度

1回答

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

我最近開始研究Reactive Extensions，主要是使用Angular 2的客戶端的可觀察性.Rex的observables和dotnet的async-await的概念似乎非常相似。是否有任何具體的例子，其中一個適用而另一個不適用。如果沒有，微軟推出Rx.Net的原因是否有其他原因，因爲觀察者站在反應擴展的核心位置。任何鏈接或實時示例就足夠了。我正在尋找差異線程/性能明智。

.net async-await rxjs angular2-observables rx.net 2017-07-15

---

1熱度

1回答

在Rx.NET中使用樹/ ReactiveUI

如何觀察樹的任何子層的屬性更改？ 考慮例如具有屬性Name和ChildNodes的屬性TreeNode。如何觀察Name任何子級的變化TreeNode？ 的使用可能是這個樣子： rootNode.FlattenTreeToObservable(x => x.ChildNodes) .WhenAnyValue(x => x.Name) .Subscribe(...) 樹節

c# reactiveui rx.net 2017-09-11

---

3熱度

1回答

RX.Net：使用重試但記錄任何異常

我是RX的新手，一直在研究錯誤處理和Retry的使用;我有以下內容（是的，我知道這不是一個'真正的'單元測試，但它讓我可以擺弄！），並想知道如何去保持重試但能夠記錄任何異常？ [Test] public void Test() { var scheduler = new TestScheduler(); var source = scheduler.C

system.reactive rx.net 2017-06-06

---

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

c# asynchronous system.reactive rx.net 2017-07-28

---

0熱度

1回答

如何單元測試Rx.Net的foreach訂閱

所有消息應發佈到消息總線： upstream.Get().ForEachAsync(async e => await _bus.Publish(e, cancellationToken)); 我想單元測試來驗證publish方法被調用正確： [Theory, AutoMoqData] public void Publish_ShouldPublishAllDataSources(

c# unit-testing system.reactive rx.net 2017-11-11

---

1熱度

2回答

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

我使用RxSwift作爲其他人開始的項目的一部分。 想要了解更多關於ReactiveX的理論，我碰到了React Native和Rx.Net。 我想確保我的理解正確如下： 陣營本地是一個Java腳本庫，允許開發者構建原生用戶界面。該庫將Javascript代碼轉換爲本地移動代碼。 RxSwift旨在實現Rx.Net的概念，但不同的是，並沒有直接聯繫陣營本地。它們的共同之處在於它們都實現了概念Rea

javascript ios react-native rx-swift rx.net 2017-08-07

---

2熱度

1回答

從頂部排出IObservable

我想要消耗一個可隨時填充的IObservable。 我有這樣的擴展方法： public static IObservable<TOut> Drain<TSource, TOut>(this IObservable<TSource> source, Func<TSource, IObservable<TOut>> selector) { return Observable.D

.net system.reactive reactive-programming reactive rx.net 2017-09-26

---

1熱度

1回答

如何在Rx.NET中使用NHibernate？

我正在瀏覽博客和reactivex.net書籍，但我很難看到如何從NHibernate查詢創建可觀察的流。在RxJava中，我會使用Observable.fromCallable - 或者甚至不是最好的方法。我知道我需要從查詢的結果中打開一個無狀態的流，但是如何做到這一點的語法不見了。 從NHibernate查詢創建Observable流的語法是什麼？另外，如果不同，如何發出堅持？ 謝謝！

nhibernate rx.net 2017-08-16

---

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已經發生了。 但我需要能夠按需發射 - 例如

c# system.reactive rx.net 2017-10-11

---