system.reactive

    0热度

    1回答

    RXSwift，检测重入异常

    我在RXSwift初学者，我有问题，我的代码 我有代码： let dartScore = PublishSubject<Int>() dartScore.asObservable() .scan(501) { intermediate, newValue in let result = intermediate - newValue
    swift xcode system.reactive rx-swift 2017-12-03

    3热度

    1回答

    Rx TestScheduler不能很好地处理返回和延迟

    我无法为包含Return和Delay的组合的observable编写单元测试。问题是TestScheduler不会发出任何通知，无论提前多长时间。 var scheduler = new TestScheduler(); var input = new Subject<bool>(); var output = scheduler.Start(() => Observable.Re
    unit-testing system.reactive 2017-10-16

    2热度

    3回答

    如何使用Observable或async/await包装异步回调？

    我正在使用与回调一起工作的网络API。所以基本上，我有一大堆的方法调用，我需要这个第三方库，像这样使用： void SendNetworkRequest(string requestType, Action<Response> callback) 我找到的代码变得有点古怪，因为我所有的方法依赖于网络来自第三方API的资源也需要自行实现回调。举例来说，在我的主场景我可能想要得到的球员资料和我的代
    c# asynchronous async-await system.reactive reactive-programming 2017-10-17

    0热度

    2回答

    收听列表中项目内的可观察事件

    我有IObservable<ImmutableArray<T>>，其中每个T都有相应的Delete命令，IObservable<Unit>。我试图在用户单击列表中的项目上的删除时作出响应。当一个项目被添加到列表中时，我想要开始监听（订阅）Delete命令。当一个项目从列表中删除时，我想停止收听（取消订阅）。如果一个项目X被添加到列表中，并且列表多次更改，我想确保我只在X上订阅了删除命令 - 当它被
    c# system.reactive 2017-10-18

    4热度

    3回答

    RxJs将流拆分为多个流

    如何基于分组方法将永不结束的流拆分为多个结束流？ --a--a-a-a-a-b---b-b--b-c-c---c-c-d-d-d-e...> 到这些观测 --a--a-a-a-a-| b---b-b--b-| c-c---c-c-| d-d-d-| e...> 正如你所看到的，a是在开始的时候，我收到b
    javascript rxjs system.reactive 2017-10-19

    3热度

    1回答

    在.NET标准库中访问调度程序IScheduler

    This question描述如何确保IObservable<>.Throttle通过将UI调度程序传递到Throttle而在UI线程上运行。但是，我的观察对象是在基于.NET Standard 1.5的共享库中定义的。在.NET标准中是否有等效的DispatcherScheduler.Instance或者我应该从使用（WPF/UWP/etc）库注入调度程序？
    c# .net system.reactive .net-standard 2017-10-21

    2热度

    1回答

    RxSwift可观察错误停止链 - 带Rx的Web服务，如何恢复？

    显然我是RxSwift的新手，虽然我消耗了大量文档和演讲，但我想我缺少一些基本概念。 在我的应用程序中，我有一个REST风格的Web服务来加载各种资源，但Web服务的基础URL在构建/开始时未知。相反，我有一个“URL解析器”Web服务，我可以使用我的应用程序包，版本和可能的环境（“生产”，“调试”或在应用程序调试设置中输入的任何自定义字符串）调用以获取基础URL，然后使用为实际的服务。 我的想法
    json swift web-services system.reactive rx-swift 2017-10-28

    0热度

    1回答

    RX.net的DropQueue机制

    我遇到了RX.net的背压问题，我找不到解决方案。我有一个可观察的实时日志消息流。 var logObservable = /* Observable stream of log messages */ ，我想通过他们正在通过网络发送之前，该串行从logObservable实时日志消息的TCP接口暴露。所以，我做到以下几点： foreach (var message in logObserva
    c# c#-4.0 system.reactive reactive-programming reactive 2017-10-28

    2热度

    1回答

    为什么不能观察，最后被调用？

    我不理解Finally方法。在这种情况下它不会起火。 [TestMethod] public void FinallyHappensOnError() { bool finallyActionHappened = false; try { Observable .Throw<Unit>(new DivideByZeroException()
    c# system.reactive 2017-11-10

    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
最新问题