Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

Emit values from Observable.from on an interval

Tags:

angular

rxjs

I have an array of items that I want to emit from an Observable on an interval.

I am using the rxjs library included in Angular 2.

This is my current solution but I feel like there is a reactive method that I am not finding. This solution also continues to produce values after the array is exhausted but it should really complete. Is there some way to drive Observable.from with Observable.interval?:

var array = [1,2,3];

var source = Rx.Observable
    .interval(500 /* ms */)
    .map(function() {
      return array.pop();
    });

var subscription = source.subscribe(
    function (x) {
        console.log('Next:', x);
    },
    function (err) {
        console.log('Error: ' + err);   
    },
    function () {
        console.log('Completed');   
    });

Output:

"Next:"
3
"Next:"
2
"Next:"
1
"Next:"
undefined
like image 505
nigel.smk Avatar asked Mar 17 '17 18:03

nigel.smk


People also ask

How do you emit multiple values in observable?

Observables can emit multiple values An Observable will emit events where a defined callback executes for each event. If you want to handle a single event, use a Promise. If you want to stream multiple events from the same API, use Observables.

What is observable interval?

Interval Method (TimeSpan) Returns an observable sequence that produces a value after each period. Namespace: System.Reactive.Linq.


1 Answers

For something simple like that, what you've done is fine except that I'd rather use the index given from interval to read the array at that given index instead of using pop which modify the original array (mixed with reactive programming it's kind of weird, isn't it =) !)

I made you another proposal so you may discover other operators maybe :

const { Observable } = Rx

const myArray = [1, 2, 3]

const interval$ = Observable.interval(500)

Observable
  .from(myArray)
  .zip(interval$)
  .do(([x]) => console.log(x))
  .subscribe(
    () => {},
    () => {},
    () => console.log('Stream ended !')
  )
<script src="https://unpkg.com/[email protected]/bundles/Rx.min.js"></script>
like image 73
maxime1992 Avatar answered Oct 02 '22 07:10

maxime1992