Tengo una serie de elementos que quiero emitir desde un Observable en un intervalo.
Estoy usando la biblioteca rxjs incluida en Angular 2.
Esta es mi solución actual, pero siento que hay un método reactivo que no encuentro. Esta solución también continúa produciendo valores después de que se agota la matriz, pero realmente debería completarse. ¿Hay alguna forma de conducir Observable.from con 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'); });Producción:
"Next:" 3 "Next:" 2 "Next:" 1 "Next:" undefinedPara algo tan simple como eso, lo que ha hecho está bien, excepto que prefiero usar el índice dado desde el interval para leer la matriz en ese índice dado en lugar de usar pop que modifica la matriz original (mezclado con programación reactiva es una especie de extraño, ¿no es así =) !)
Te hice otra propuesta para que puedas descubrir otros operadores tal vez:
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/rxjs@5.1.1/bundles/Rx.min.js"></script>