rx.net

    0热度

    1回答

    是否有像StartWith这样的扩展名，但是对于可观察序列的结尾？

    我想追加一个额外的“闭幕”项目给我的观察序列。是否有像StartWith那样的反应性LINQ扩展，但是对于可观察序列的结尾？ 这里是我想要的一种近似，虽然它似乎没有火灾的最后一个元素： public static IObservable<TSource> EndWith<TSource>(this IObservable<TSource> source, TSource element) {
    c# system.reactive rx.net 2016-11-12

    0热度

    1回答

    等待工作的.NET任务

    我想在等待工作的服务器上创建线程。 我想每个访问该网站的用户有1个线程。它使用add.sleep（100）创建一个while循环，但似乎效率不高。我们跟踪属于每个访问者的每个任务，以便我们可以访问与Winform相关的对象。 所以我们需要线程，因为我们已经把许多年放在winforms中，而且很多代码是在代码隐藏表单中，因此我们必须为每个用户启动一个MainForm实例，并在用户访问现场。 html
    .net task rx.net 2016-09-29

    4热度

    1回答

    如何获取IObservable的最后一个已知值？

    假设我正在使用Rx.Net构建图像编辑器。用户可以使用鼠标操作画布。应用的操作取决于当前选择的工具。例如，可能有一个“绘图”工具和一个“擦除”工具。一次只能选择一个工具。 我有三条流;一个用于鼠标事件;一个用于通过点击鼠标发出的命令;另一个用于工具的选择： IObservable<ITool> toolSelection; IObservalbe<MouseState> mouse; IObs
    c# system.reactive rx.net 2016-07-06

    2热度

    2回答

    节流，但如果它们来得太晚，就会丢弃结果

    我正在编写一个用户可以在其中输入搜索词的用户界面，并且列表可以获得不断更新的提供建议。 我的第一个虽然是Rx原始节流阀是一个完美的比赛，但它让我一半。 建议需要一段时间来获取，所以我不会在UI线程上异步获取它们。 问题是，如果用户再次输入油门时间间隔，我想放弃/跳过/丢弃结果。 例如： 时间开始，并且用户按下一个键：0毫秒 节气门被设置为100毫秒。 获取需要200ms。 在150ms的用户与油门
    c# .net system.reactive reactiveui rx.net 2016-08-25

    1热度

    1回答

    使用C中的RX自动保存＃

    我想实现自动保存功能。我有两个观测量： IObservable<Unit> changes：发出一个项目的每个用户编辑文本 IObservable<Unit> saves时间：发出的每一个保存按钮被按下 现在时间我想结合保存事件那些成第三流writeBack。这个流有一个用户，它将当前文本写入数据库。 如何创建writeBack流，以便它满足以下属性？ 一个未保存的变化被写回，如果还没有发生任何改
    c# system.reactive autosave rx.net 2017-01-22

    0热度

    1回答

    Rx.NET不会触发onError也不onComplete

    我正在学习Rx.NET，并在下面的示例代码中尝试执行异步任务观察日期时间选择器值更改事件。 onNext运行完美，但onError和onComplete不。我究竟做错了什么？ private void frmReporting_Load(object sender, EventArgs e){ dtPickerValueChanged = Observable.FromEventPatt
    c# events asynchronous rx.net 2017-01-25

    4热度

    2回答

    如何使用Reactive Extensions进行状态轮询？

    已经有使用无（Database polling with Reactive Extensions） 我有一个类似的问题在数据库查询一个很好的问题，但有一个转折：我需要从以前的结果，养活一个值到下一个请求。基本上，我想查询此： interface ResultSet<T> { int? CurrentAsOfHandle {get;} IList<T> Results {get
    c# system.reactive rx.net 2017-01-27

    0热度

    1回答

    如何筛选子可观察项至少有x项的Observable

    如果有IObservable子项的IObservable对象，那么如何筛选主观察值以仅包含子属性至少具有X个数的实例项目。 例如，以下测试用例具有包含2个MyClass的IObservable。第一个包含5个整数的可观察值和2的第二个。所以我的问题是如何过滤MyClass的IObservable以仅包含包含4个或更多数字的实例？ [TestClass] public class TestClas
    c# system.reactive rx.net 2017-03-20

    1热度

    1回答

    被动扩展只适用于返回集合的API调用吗？

    我有一个代理调用多个REST API来为UI创建课程粒度输出。 UI是用KnockoutJS构建的。我正在使用任务/异步方法异步调用API。只有1或2个API返回一个列表，所有其他的都返回平坦值对象。 Rx可以用于合并那些不返回集合的API的结果吗？由于输出不是一个集合，这意味着它不是一个事件流，所以将这种API调用与Rx结合起来反对Rx指南？
    rx-java system.reactive reactive-programming rx.net 2016-12-14

    0热度

    3回答

    Rx：通过匹配ID进行连接

    我们假设有两个观测值o1, o2。第一个接收来自内部进程的事件（经过非常长的计算完成），第二个接收来自REST端点的外部事件（表示另一个外部组件也完成）。事件数据只是一个ID。 现在我想要设计一个工作流程，以便只有当两个观察对象中都存在一个ID时，才会发出新事件（即内部和外部计算完成时）。 设在一个时间点o1包含的ID {1,2,3}，那么我想这些情况来区分： 正常情况下：例如ID 2抵达o2。两
    rx-java rx.net 2017-05-26
最新问题