Create infinite repeatable Observable from array

Let's say I have an array <strong>items</strong>

I know I can create an observable from this array using

Rx.Observable.fromArray(items)

How do I create a lazily infinitely repeating observable from this (i.e.: repeating the items as long as they are being requested)?

Tried

Rx.Observable.fromArray(items).repeat()

But this doesn't execute lazily and therefor locks up the browser.

Answer1:

You cannot do this with an Observable. You way want to look at using an Enumerable.

The Enumerable flavor of Reactive Extensions is known as Interective Extensions.

Answer2:

I'm still a newcomer to RxJS, so perhaps what I am proposing is complete madness, but could something along the lines of the following work for this?

var items = [1, 2, 3, 4, 5]; var infiniteSource = Rx.Observable.from(items) .map(function (x) { return Rx.Observable.return(x).delay(1000); }) .concatAll() .doWhile(function(_) { return true; /* i.e. never end */ }); infiniteSource.subscribe(function(x) { console.log(x); });

I have an example here: http://ctrlplusb.jsbin.com/sihewo/edit?js,console

The delay is put in there so as not to flood the console. In terms of the "until no longer needed part" perhaps an unsubscribe or other mechanism can be injected into the doWhile?

人吐槽 人点赞

Recommend

Comment

用户名: 密码:
验证码: 匿名发表

你可以使用这些语言

查看评论:Create infinite repeatable Observable from array