rxjs

1热度

1回答

比方说，我有处理错误时需要原来的参数如下同步代码： var input = createInput(123); try { doWork(input); } catch (err) { handleError(input, err); // error handling requires input } 什么是原来的参数传递给错误处理程序的最佳方式？ Rx.Obse

2热度

2回答

创建一个主题

我已经在RxJS中看到过这个，但是我还没有在RxJava中找到相应的东西。有没有人有任何想法如何在java中设置这样的东西？ RxJS Subject.create(observer, observable) 创建一个从指定观察者和可观察的受试者。参数观察者（观察）：用于将消息发送到所述受试者的观察者。 observable（Observable）：用于订阅从主题发送的消息的observabl

0热度

1回答

Streams有条件地响应热Observable？

我想要一个组件，异步（并有条件地）对鼠标事件流作出反应。这里有一个简单的场景：您悬停在a {@time: 0}，组件变成A {@time:4}，但那时，用户已经徘徊在b {@time:2}然后c {@time:4}。所以组件需要从A切换到C。 MouseEventStream: a-b-c-------d-e-f-g--h--------|-> ComponentState: *---A---

2热度

2回答

流如何适合Flux应用程序？

我有a webapp它打印在服务器上运行的命令行程序的输出。该输出使用RxJS streams（source）发送。我试图重构这个应用程式通量架构（从ReactJS人），它强制在一个方向上的应用流量： Action => Dispatcher => Stores => View-Controller 而且我不知道我应该如何使用流在此助焊剂应用：是否每个流事件都将一个新的Action激发到分

1热度

3回答

如何设置Rx.Observable.fromEvent以使用jQuery过滤的事件

有很多Rx.Observable.fromEvent(element, eventName)的示例使用jQuery选择作为捕获事件的元素。然而，Rx可能仅侦听来自jQuery过滤事件设置的事件吗？ //Bind the event on body but only respond to events that match the filter $('body').on('click', '.aC

0热度

1回答

是否可以使用RxJS搜索静态加载的JSON列表？

嗨只是想知道，如果它可以搜索使用RxJS已经存在的JSON对象/数组？只看到有Ajax请求的例子。我有JSON已经加载，但喜欢使用RxJS对其进行过滤。任何很好的例子？希望这是可能的:)

0热度

1回答

如何获取使用.fromEvent创建的Observable的事件名称

我试图限制来自常见消息总线的事件应发送到服务器。允许的事件在outgoingEvents数组中。问题是要正确发送他们的服务器我需要事件名称。 var Events = new EventEmitter(); var outgoingEvents = [ 'messageSubmit' ]; var outgoingMessages = Observable.fromArray(

2热度

1回答

FRP，角度和全局事件处理程序

我刚开始使用Bacon.js，它确实很棒。虽然有时候我很难找到正确的做事方式。例如，我想要一个带有可拖动部分的角度指令。我无耻地选择了某人的jsBin，并试图修改该代码的角度我想制作一个可调整大小的列表。所以，如果我做这样的事情在列头指令 link: (scope, element, attrs)-> el = element.find('.column-separator')

1热度

1回答

我如何使用RxJS-jQuery和browserify的要求

我在我的应用中使用jQuery。我将所有源文件与browserify捆绑在一起。因此，我导入npm version of jQuery： const $ = require('jQuery'); 我也用RxJS和喜欢用jQuery Bindings for the Reactive Extensions for JavaScript，但如果我require('rxjs-jquery')我只得到

2热度

3回答

RxJS.fromWebSocket与Socket.io

我想创建一个使用Rx.DOM.fromWebSocket与Socket.io主题。我真的迷失了 - 我在哪里可以找到Socket.io实现的协议？ var rxSocket = Rx.DOM.fromWebSocket( 'ws://localhost:12345', 'ws', function (e) { console.log('Opening