rx.net

    2热度

    2回答

    我有一个使用MVVM模式编写的跨平台项目(没有使用特定的框架,只是自编写的实现)。项目有几个独立的模块,每个模块都有几个页面。每个页面都有ViewModel和某种负责数据导向逻辑(获取,保存,删除,转换等)的管理者。因此,数据流看上去只有这个: VM - >管理 - >服务 - >管理 - > VM 当虚拟机装载它要求经理数据。 Manager执行服务调用,获取数据,从DTO构建模型集合,将此集合

    0热度

    1回答

    我想知道在Timeout触发之前获取序列中最新元素的最佳方法是什么? 我有一个代码,不时ping通远程服务,我希望能够确定一个已经脱机的代码。 使用我想出了这个超时扩展: heartbeatResponseObservable.Timeout(Timeout, Observable.Return(new HeartbeatBusMessage.Timeout())) 这有点儿工作,但它不允许我

    5热度

    3回答

    我有一个课程需要参加一系列活动,并推出另一个活动。 所有事件都使用反应性扩展(RX)。使用.OnNext将输入的事件流从外部源推送到IObserver<T>,并使用IObservable<T>和.Subscribe推出输出的事件流。我正在使用Subject<T>来管理这个,在幕后。 我想知道RX中有哪些技术暂时暂停输出。这意味着传入的事件会建立在内部队列中,当它们未被暂停时,事件将再次流出。

    2热度

    1回答

    我对鼠标左键的状态流: var leftMouseButton = mouse.Select(x => x.LeftButton).DistinctUntilChanged(); 然后我Window这给我一个观察的代表鼠标的拖动观测的: var leftMouseDrag = mouse .Select(mouseState => new Point(mouseState.X, mo

    7热度

    2回答

    我试图解析表示消息的传入字节流。 我需要拆分流并为每个部分创建一个消息结构。 消息始终以0x81(BOM)开始,以0x82(EOM)结尾。 start: 0x81 header: 3 bytes data: arbitrary length stop: 0x82 数据部分使用转义字节0x1B(ESC)转义:每当在数据部分中的一个字节包含控制字节{ESC,BOM,EOM}中的一个,它带有前

    3热度

    1回答

    我已经开始考虑在事件存储中使用Reactive Extensions。作为一个概念证明,我想看看是否可以让Rx使用事件流,并输出按类型分组的事件计数,以用于一秒的窗口。 所以,说我消费名为“订单”甲流,我想看看下面出现在控制台类似: OrderCreated 201 OrderUpdated 111 (第二遍..) OrderCreated 123 OrderUpdated 132 等