javascript - rxjava中的rxjs concatAll()等效项

我的目标是模拟具有一定随机（预定义）延迟的事件。我正在模拟RxJs中的事件，如下所示：

var events = [
     {id: 1, qty:   23, delayMs:   0},
     {id: 1, qty:  231, delayMs:   3},
     {id: 1, qty:  232, delayMs:   1},
     {id: 1, qty:  233, delayMs:   2},
     {id: 1, qty:  234, delayMs: 100},
     {id: 1, qty:  235, delayMs:  50},
     {id: 1, qty:  236, delayMs:  50},
     {id: 1, qty:  237, delayMs:  50},
     {id: 1, qty:  238, delayMs:  50},
     {id: 1, qty:  239, delayMs:  50},
     {id: 1, qty: 2310, delayMs:  50},
     {id: 1, qty: 2311, delayMs:  50},
     {id: 1, qty: 2312, delayMs: 100},
     {id: 1, qty: 2313, delayMs:  50}
 ];

var rawEvents$ = O.from(events).map(o => O.return(o).delay(o.delayMs)).concatAll();

通过上面的代码，我得到了预期的模拟事件流。我试图在Java中实现相同的功能，但看起来Java没有concatAll（）。到目前为止，我已经编写了以下代码：

Observable rawEvents$ = Observable.concat(Observable.from(events).map(o -> Observable.just(o).delay(o.get("delayMs"), TimeUnit.MILLISECONDS)));

但是，由于我使用的是concat（）而不是concatAll（），所以我无法以指定的延迟输出事件流。 Java中的concatAll（）等效什么？

最佳答案

不是RxJAva方面的专家，但是我认为值得尝试使用concatMap（应该等效于map(...).concatAll）。如果排序不正确，我将尝试通过增加延迟来对事件数组进行排序。