rxjs

    2热度

    1回答

    你是如何做到的? RxJs对我来说仍然是个谜。 我尝试这样的东西: filterChanges .delay(400) .replay() .reduce(function(acc,x) { return acc.concat(x) }, []) .subscribe(function(changes) { console.log(changes

    5热度

    4回答

    我试图进入反应式编程。我使用数组函数(如map,filter和reduce)来减少所有的时间,并且爱我可以在不创建状态的情况下进行数组操作。 作为一个练习,我试图用RxJS创建一个可过滤的列表而不引入状态变量。到底它应该工作与此类似: 我想知道如何与天真的JavaScript实现这一目标或AngularJS/ReactJS但我想用什么,但RxJS,并不会产生这样做状态变量: var list =

    3热度

    1回答

    假设我有一个文件流filesStream和一个函数uploadFile,它返回一个值(Rx.Observable.fromPromise(...))的流。在流文件可以通过简单的flatMap上传: filesStream.flatMap(uploadFile) 我需要的是从filesStream与相应的响应从uploadFile zip文件: zippedStream.subscribe(

    3热度

    2回答

    有没有办法检测对象是否是流类的实例?例如RxJS或Bacon.js流。 我正在寻找的是类似 function isStream(obj) { // if obj is RxJS or Bacon Stream return true, otherwise false } 什么是这样做的最可靠的方法是什么?

    7热度

    1回答

    observable.publish().refCount()和observable.share()之间的实际区别是什么。什么是我们不想使用share的情景的一个例子?

    1热度

    1回答

    在RXJS自动填充示例中,您可以筛选键盘事件,但是如何筛选mouseenter和mouseleave事件?

    1热度

    1回答

    具有简单Rxjs流,我遇到这种情况: Rx.Observable .fromArray([1,2,3,4,5,6]) // if commented from here .windowWithCount(2, 1) .selectMany(function(x) { return x.toArray(); }) // to here .. th

    3热度

    1回答

    考虑下面的代码示例: import R from 'ramda'; import {Observable} from 'Rx'; var allClicks_ = Observable.fromEvent(window, 'click').share(); var getClicks = function(klass) { return allClicks_.filter(e

    0热度

    3回答

    RxJs似乎没有catch()方法的变体,它只允许捕获某种类型的异常。但很多时候我发现自己处于需要这种操作员的状态。 例如,成像我需要解析日志文件的每一行并打印解析的消息。日志文件的某些行可能已损坏,但我真的不在乎,只想输出此日志文件的“日志消息已损坏”并继续到下一行。 如果catch()确实让我们指定一个特定类型的错误捕获并通过所有其他错误,我们就可以做到像伪代码一些东西下面 readLogs(

    0热度

    1回答

    我有在this.store存储数据并采取键盘事件在this.stream 模块this.store和this.stream之间的关系是如下 this.stream.subscribe(function(keyCode){ this.store.add(100) }); 现在我正在编写针对这些事件的测试用例。我想知道什么时候我分别点击键盘3次,中间结果会是什么。 所以测试用例如下: