时间戳

首页 > 解决方案 > 使用 RxJs 实现队列系统

rxjs - 使用 RxJs 实现队列系统

问题描述

我们已经用 Javascript 实现了一个队列系统。

消费者记录项目并在内部将其插入队列（这是存储在会话存储中的数组）。

时间间隔用于使多个项目出队并将这些项目发送到后端。

我们如何使用 Rxjs 和流来实现这一点？

标签： rxjsrxjs5

解决方案

const queue = new Rx.Subject();

const queueProcessing = queue
  .mergeMap(i => Rx.Observable.of(i)
              .do(val => console.log('processing item: ' + val))
              .delay(2000) /* stub processing time*/
           , 2) /* concurrency */
  .subscribe();

queue.next('asdf');
queue.next('as');
queue.next('zxvc');
queue.next('`1`');
queue.next('zx');
queue.next('234');
queue.next('5');
queue.next('645');
queue.next('asdf');
queue.next('3');
queue.next('2');
queue.next('34');
queue.next('asdf');
queue.next('5');
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.5.1/Rx.js"></script>

包含一个演示“.mergeMap处理”功能，它只是在延迟后发出值。每次您想将项目添加到队列中时，您.next()都会将其添加到主题中。

推荐阅读