reactive-extensions-js

3热度

1回答

我有两个行为主题流，我试图forkJoin没有运气。正如我想象的那样，它给出了它的最后两个值。这可能以某种方式实现它吗？它不在主题后面调用。 let stream1 = new BehaviorSubject(2); let stream2 = new BehaviorSubject('two'); Observable.forkJoin(stream1, stream2) .s

10热度

2回答

RxJs：轮询，直到间隔进行，或者正确的数据接收

我如何与RxJs的浏览器中执行以下情形：提交数据排队等候处理取回作业ID 调查另一个端点每1秒，直到结果可用或60秒已通过（再失败）中级解决方案，我想出来的： Rx.Observable .fromPromise(submitJobToQueue(jobData)) .flatMap(jobQueueData => Rx.Observable .

0热度

1回答

在可观察的数组中增加单独的值 - RxJS

我一直在试图解决这个问题一段时间了，我猜这是一个相当普遍的问题，但我想要做的是增加来自观察到，并增强与观察或promiselike 发生所以我想类似如下： function augment(person: Person): Observable<PersonWithAddress> { // does ajax call or something } const items$: O

4热度

1回答

RxJS间隔无延迟

下面的代码发出5000ms后int，然后又在每一个5000ms后： let evens = Observable.interval(5000) .map(i => { return i * 2; }); evens.subscribe((i) => { console.log(i); }); 是否有可能做到这一点，但马上有第一个结果（0ms

1热度

2回答

将多个Observable与不同的操作/操作结合

我正在构建一个Angular2应用程序，所以我习惯了Observables和Reactive Extensions作为一个整体。我正在使用TypeScript和rxjs。现在我已经有了一个可观察的，或者如果你愿意的话，一些对象的数组。让我们说个人对象。现在，我已经有了人，画线的其他两个流，并希望这些，所以我得到一个流这始终是最新的组合： var people$ = getPeople();

2热度

1回答

如何在rx.js中使用bufferWithCount创建第一个项目？

说你做这样的事情： Rx.Observable.range(1, 5).bufferWithCount(2, 1).subscribe(console.log); 这将返回： [1, 2] [2, 3] [3, 4] [4, 5] [5] 我想对于结果看起来像（基本上迫使第一个值发射）： [<userDefined>, 1] [1, 2] [3, 4] etc...

2热度

2回答

combineAll不空数组

JSBIN Sample 上发射我有一个可变集的子组件（POJO对象），每个具有其自己的状态流。每次用户触发addChild/removeChild/clearChildren时，都会使用#switchMap发送一组新的子状态流。到现在为止还挺好！（和RxJS一样惊讶！）与Rx.Observable.from(arrayOfStateStreams).combineAll()只要arrayOf

0热度

2回答

RxJS/ReactiveX正确的模块通信

我很新的反应编程，但已经恋爱了。然而，我的大脑仍然很难转向它。我试图按照“避免使用主题”和“避免不纯的功能”以及“避免命令式代码”的所有建议。我发现很难实现的是简单的交叉模块通信，其中一个模块可以注册“action”/ observable，另一个可以订阅并对其作出反应。一条简单的消息总线可能会工作，但这会强制使用主题和我试图避免的命令式代码风格。因此，这里是一个简单的出发点，我用打： //

0热度

1回答

嵌入式查询人口RxJs

我无法弄清楚如何解决以下问题。有对象类型： Box { Fruit[n]: { Kinds[n]: { id: string; name: string; } } } 我fuits的箱子从API调用作为可观察到的（Angular2）水果[]然后，我想与其他填充它的“导航属性” API呼叫什么回馈一个观察，以及像这样： Bo

3热度

2回答

RxJS 5任务队列，如果任务失败则继续

想象一下，我们有一个触发AJAX请求的HTML页面。我们希望确保AJAX请求按顺序执行。直到前一个AJAX请求完成或发生错误，下一个AJAX请求才会被触发。我试图通过使用RxJS concatMap的任务队列对此进行建模。每个AJAX请求都被建模为Observable。如果AJAX请求成功完成，一切都很好，但是如果错误发生，那么队列中的下一个任务就不会执行。下面是一个例子，使用setTimeo