Using Rxjs, looking for a cleaner solution for combining array streams

Question

My issue is not with having working code, but my solution to combining streams of arrays seems fragile and I am sure Rxjs has a better solution. The following is and example of what I have written:

var all$ = Rx.Observable.combineLatest(
    basicArray$, fastArray$, slowArray$,
    function(basic, fast, slow){
        return basic.concat(fast).concat(slow);
});

My goal is three in -> one out and only when there all three are new.

Calvin Belden · Accepted Answer · 2016-03-07 14:44:35Z

1

Using a utility (like lodash's flatten method), you can accomplish the same using the following:

var all$ = Rx.Observable.combineLatest(basicArray$, fastArray$, slowArray$)
    .map(_.flatten);

Looking at your last comment, however, I don't think your code works as expected. The stream resulting from combineLatest will emit a new item as soon as any of the streams emits.

Based on your description, the zip operator might be more appropriate: https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/zip.md

answered Mar 7, 2016 at 14:44

Calvin Belden

3,1141 gold badge21 silver badges21 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

jamesRH Over a year ago

.zip makes sense in making a better solution. Thank you for that feedback

Collectives™ on Stack Overflow

Using Rxjs, looking for a cleaner solution for combining array streams

1 Answer 1

1 Comment

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Your Answer

Sign up or log in

Post as a guest

Related