reactive-programming相关内容

阅读使用TcpClient的和无扩展从流连续字节流

考虑下面的代码： 内部类节目 { 私有静态无效的主要（字串[]参数） { VAR的客户=新的TcpClient（）; client.ConnectAsync（“本地主机”，7105）.Wait（）; VAR流= client.GetStream（）; 无功可观察= stream.ReadDataObservable（）重复（）; 变种期从D =在observable.B ..

发布时间：2016-09-26 20:04:26 c# stream system.reactive tcpclient reactive-programming C#/.NET

缓冲区在处理项目

我有定期触发一个事件。让我们假设处理事件，大约需要1秒。与其等待1秒对每个接收到的事件我希望积累事件 ，直到最后的处理完成。当处理完成我想要PROCES我最后的处理过程中接收到的事件数据： E1 E2 E3 E4 E5 E6 E7事件发生 --------------------------------------------- ---------------------------- ..

发布时间：2016-09-19 22:05:21 c# .net system.reactive reactive-programming C#/.NET

与无扩展事件重新排序

我试图重新安排在不同的线程到达的无序事件 是否有可能创造这些大理石图相匹配的反应扩展查询： S1 1 2 3 4 S2 1 3 2 4 结果1 2 3 4 和... S1 1 2 3 4 S2 4 3 2 1 结果1234 这就是：只有发布版本号顺序结果 我得到的最接近是使用加入。打开一个窗口，每次 ..

发布时间：2016-09-08 19:22:40 c# .net system.reactive reactive-programming C#/.NET

如何获得的总和"最后"小数将N热观测<的物品;实例？

编辑：在2013年9月15日 - 我描述我的方案进一步分成步骤来帮助大家理解我的处境要好。增加了对下载整个应用程序太源。如果你想跳到原来的问题，向下滚动到最后的标题。请让我知道这个问题。谢谢 摘要 阿拉斯加州首府朱诺有一个AST（阿拉斯加州警官）总部大楼，他们想显示大屏幕，自动显示和更新的一个数字。这个数字被称为（犯罪智商指数）或CQI CQI基本上是一个计算的数字显示状态的当前 ..

发布时间：2016-08-30 14:12:46 c# system.reactive reactive-programming observable C#/.NET

如何更新R中闪亮的按钮标签？

第r闪亮的网站有一个如何更新很好的例子的各种基于用户输入的输入类型的标签和值。但是，我找不到任何按键。具体来说，根据用户的输入如何更新一个按钮的标签？ 解决方案 您可以动态创建像这样的按钮，同时更新标签： 库（闪亮）UI =（pageWithSidebar（ headerPanel（“测试闪亮应用程序”）， sidebarPanel（ 为textInput（“sample ..

发布时间：2016-08-16 21:52:44 r button shiny reactive-programming 其他开发

调用的setState在渲染是不可以避免的

阵营文件指出，在渲染函数应 纯粹的这意味着它不应该使用 this.setState 在里面。但是，我相信，当国家决定于“远程”，即从阿贾克斯独特叫声唯一的解决办法的结果是的setState（）在渲染函数 在我case.Our用户应该能够登录。登录后，我们还需要检查用户的访问（Ajax调用）来决定如何显示PAGE电泳code是像这样 React.createClass（{ 渲染：功能 ..

发布时间：2016-07-21 11:18:54 asynchronous reactjs reactive-programming 其他开发

积累和流重置价值

我在玩无编程，使用RxJS和偶然的东西我不知道如何解决。 比方说，我们实现一个自动售货机。您插入一枚硬币，选择项目，并且该机免除项目并返回改变。我们假设价格永远是1分钱，所以插入四分之一（25美分）应返回24美分回来，等等。 在“刁钻”的部分是，我希望能够处理情况下，像用户插入2硬币，然后选择一个项目。或选择项目不插入一枚硬币。 他很自然地实现插入硬币和所选项目的数据流。然后，我们可以介绍一 ..

发布时间：2016-07-21 10:32:22 javascript asynchronous reactive-programming rxjs 前端开发

有没有一种方法来订阅的观察者异步

给定一个同步观测 ，有没有办法做到这一点： observable.SubscribeAsync（观察员）; 和对所有方法观察异步调用或者是说我的东西在创建观察者时处理？ 解决方案 您可能想看看 ObserveOn 和 SubscribeOn （ ..

发布时间：2016-07-21 10:16:31 c# multithreading asynchronous system.reactive reactive-programming C#/.NET

异步RestAPIs与RxJava / Jersey2。线程的问题？

我们在使用反应式编程原型设计REST API的过程。 如上图所示，我们保持3层同我们在previouse同步API设计中使用; http://oi59.tinypic.com/339hhki.jpg 使用Jersey2将处理请求/反序列化JSON并移交给业务层实施 API层。 服务层，它实现了业务logic.Implemented采用反应式编程（RxJava） 这是用于维修服务L ..

发布时间：2016-07-21 10:07:58 java asynchronous jersey-2.0 reactive-programming rx-java Java开发

反应式编程 - RxJS VS EventEmitter Node.js的中

最近，我开始寻找它的反应式编程的概念工作 RxJS 并RxJava（来自Netflix）库。 Node.js的工作原理事件循环的基础上，为您提供所有异步编程和后续节点库，例如“集群”帮助您获得最佳的出你的多核机器的阿森纳。 Node.js的和还为您提供的EventEmitter功能，您可以订阅的事件和异步就此采取行动。 在另一方面，如果我理解正确RxJS（和一般的反应式编程）工作在事件流的原则 ..

发布时间：2016-07-21 09:54:28 javascript node.js asynchronous reactive-programming rxjs 前端开发

HOWTO回调异步函数从RX订阅？

我想接收一个内部认购回拨一个异步函数。 例如。这样的： 公共类消费 { 私人只读服务_service =新服务（）; 公共ReplaySubject＆LT;串GT;结果=新ReplaySubject＆LT;串GT;（）; 公共无效触发（） { Observable.Timer（TimeSpan.FromMilliseconds（100））订阅（异步_ ..

发布时间：2016-07-21 09:27:07 c# asynchronous system.reactive reactive-programming C#/.NET

RxJava抓取观测量在并行

我需要在落实RxJava并行异步调用一些帮助。我拿起一个简单的用例，其中要显示的第一个电话取（而搜索）的产品清单（瓦）。随后调用出去取（A）审查和（B）产品图片 经过多次尝试之后我得到了这个地方。 1与可观察到的LT;瓷砖＆GT; sea​​rchTile = searchServiceClient.getSearchResults（SEARCHTERM）; 2清单＆LT;瓦片GT; al ..

发布时间：2016-07-21 09:17:50 java asynchronous reactive-programming observable rx-java Java开发

如何使用观测量来实现轮询？

我已经参数化应该执行REST调用各5第二，不同的PARAMS： 观测restCall = api.method1（参数1）; 我需要创建观测投票，将执行restCall每次5第二，不同的参数1。如果API调用失败，我需要得到错误，使下一个电话5秒钟。电话之间的间隔应在restCall完成（成功/错误）只衡量。 PS：即时通讯目前使用RxJava，但.NET示例也将是不错的。 解决方案 ..

发布时间：2016-07-20 11:00:47 c# async-await system.reactive reactive-programming rx-java C#/.NET

是否有可能建立使用非功能性的语言反应应用？

我想知道如果无功申请宣言背后的原理可以使用的非功能性的语言来实现 有人说，既然FP使用一成不变的状态和无副作用的函数，它们更容易实现同步，分布式和有弹性的系统。 但是，我们如何才能做到这一点使用Java例如？ 有一些框架，如Apache的骆驼，有一些组件的工作，例如骆驼RX 和骆驼SEDA 。 这些是不够的框架？ 我会尽力澄清我的问题： 我觉得反应式编程的新的编程范式，和一个新的编程范 ..

发布时间：2016-05-22 12:39:56 java functional-programming apache-camel reactive-programming Java开发

如何观察RxAndroid网络变化

我使用给出的这里。 我把那些code块在我的项目的util包类。然后在主活动课，我写这个.. 类MenuActivity {//变量声明 私人最终CompositeSubscription mConnectionSubscription =新CompositeSubscription（）;@覆盖 保护无效的onCreate（捆绑savedInstanceState）{ // UI元素 ..

发布时间：2016-03-08 10:42:58 android reactive-programming rx-java rx-android 移动开发

管理与RxJava相同的请求

假设我有一个读取器的读取图像从一个单独的线程给定链路。该图像将被缓存在内存中。一旦图像已经被缓存的读取器不会重新获取链接。取出器被认为是一个可观察到的。可能有许多订户询问读取器为图像。经过第一次的用户订阅取出器，取出器将拍摄网络。但是，如果有第2个用户来订阅，然后，取出器应该不会拍另一个请求，同时它已经被前取之一。在此之后，如果取结束，两个订户将得到的图像。现在，如果有自带一个3户，取出器会发出图 ..

发布时间：2015-12-03 17:23:30 android reactive-programming rx-java 移动开发

如何创建onclick事件Android的可观察到的？

我是新的反应式编程。所以，我有，当从事件创建流问题一样的onClick，ontouch ... 谁能帮我解决这个问题。 感谢。 解决方案 您会做这样的事 观测＆LT;视图＆gt; clickEventObservable = Observable.create（新Observable.OnSubscribe＆LT;视图＆gt;（）{ @覆盖 公共无效电话（ ..

发布时间：2015-12-02 20:26:31 android reactive-programming rx-java 移动开发

结合最新从观察到的观测值

假设我有一组的URI，我监测的可用性。每个URI是要么“向上”或“向下”，和新的URI并监控可以加入到该系统中的任何时间： 公开枚举ConnectionStatus { 向上， 向下 } 公共类WebsiteStatus { 公共字符串乌里 { 得到; 组; } 公共ConnectionStatus状态 ..

发布时间：2015-11-26 19:10:57 c# .net system.reactive reactive-programming C#/.NET

使用无功扩展处理以正确的顺序多个响应

状况 我有一个，其中一个请求产生了两个响应系统。请求和响应都有相应的观测值： 的IObservable＆LT; RequestSent＆GT; _要求; 的IObservable＆LT; MainResponseReceived＆GT; _mainResponses; 的IObservable＆LT; SecondResponseReceived＆GT; _secondaryResponses ..

发布时间：2015-11-26 10:43:09 c# .net system.reactive reactive-programming C#/.NET

反应性扩展基于特定数目的并行处理

我是新来的无功扩展。我有对象采集和调用一个方法为每个对象和方法返回布尔。相反，通过每个使用每个回路并调用方法循环的，有没有办法无扩展可同时调用（fork和join）方法的对象（例如5在一个给定的数字时间）后第一个完成，6应该调用方法，它应该继续下去，直到所有的对象都做了。 我AP preciate你的回应。 解决方案 的IObservable＆LT;布尔＆GT; someBoolAsyncM ..

发布时间：2015-11-26 09:45:59 .net system.reactive throttling reactive-programming C#/.NET