Tag: 反应编程

反应式和function反应式编程之间的区别

最近我一直在研究反应式编程,我发现很难find反应式和function反应之间区别的很好的描述。 简单地说,反应式编程是使用函数方法/范式实现的,而不是使用声明式或面向对象的范式?

RxJava并行获取可观测数据

在RxJava中实现并行asynchronous调用需要一些帮助。 我select了一个简单的用例,其中FIRST调用获取(而不是search)要显示的产品列表(Tile)。 随后的呼叫出去并取(A)REVIEWS和(B)产品图像 经过几次尝试,我到了这个地方。 1 Observable<Tile> searchTile = searchServiceClient.getSearchResults(searchTerm); 2 List<Tile> allTiles = new ArrayList<Tile>(); 3 ClientResponse response = new ClientResponse(); 4 searchTile.parallel(oTile -> { 5 return oTile.flatMap(t -> { 6 Observable<Reviews> reviews = reviewsServiceClient.getSellerReviews(t.getSellerId()); 7 Observable<String> imageUrl = reviewsServiceClient.getProductImage(t.getProductId()); 8 return Observable.zip(reviews, imageUrl, (r, u) -> { 9 t.setReviews(r); 10 t.setImageUrl(u); 11 return t; […]

比较core.async和Functional Reactive Programming(+ Rx)

在将Clojure的core.async与所谓的Reactive Extensions (Rx)和FRP进行比较时,我似乎有点困惑。 他们似乎也在处理类似的asynchronous性问题,所以我想知道主要的区别是什么,在哪些情况下,哪一个更受欢迎。 有人可以解释吗? 编辑:为了鼓励更深入的答案我想提出更具体的问题: Core.async允许我编写同步代码。 但据我了解,FRP只需要一层嵌套的callback(处理逻辑的所有函数都作为parameter passing给FRP API)。 似乎这两种方法都不需要callback金字塔 。 的确,在JS中我必须多次编写function() {…} ,但是主要的问题, 嵌套的callback函数在FRP中也没有了。 我得到它的权利? “ FRP与控制stream程完成消息的交stream”您能(某人)给出一个更具体的解释吗? 难道我不能像我通过频道那样通过玻璃钢的可观察端点吗? 总的来说,我明白这两种方法在历史上来自哪里,而且我也尝试过两种教程。 不过,我似乎被不明显的差异“瘫痪”了。 是否有一些代码很难用其中一种编写代码,而使用其他代码 ? 那build筑原因是什么?

什么是“回拨地狱”以及RX如何解决这个问题?

有人可以给一个清晰的定义,一个简单的例子,解释什么是一个“callback地狱”的人不知道JavaScript和node.js? 什么时候(在什么样的设置)发生“callback地狱问题”? 为什么会发生? “callback地狱”总是与asynchronous计算有关吗? 或者也可以在单线程应用程序中“callback地狱”? 我在Coursera参加了Reactive Course,Erik Meijer在他的一个演讲中表示,RX解决了“回拨地狱”的问题。 我问在Coursera论坛上什么是“回拨地狱”,但我没有明确的答案。 通过一个简单的例子解释“callback地狱”之后,你能否展示RX如何解决这个简单例子中的“callback地狱问题”?