Comment rendre compte à rebours avec RxJS Observables?

J'ai du mal à créer un compte à rebours de la minuterie à l'aide des Observables, les exemples à http://reactivex.io/documentation/operators/timer.html ne semblent pas fonctionner. Dans cet exemple précis, l'erreur liée à timerInterval n'étant pas une fonction de l'Observable retourné à partir de la minuterie.

J'ai aussi fait des expériences avec d'autres approches et le meilleur que j'ai trouvé est:

Observable.interval(1000).take(10).subscribe(x => console.log(x));

Ici, le problème est-il compte de 0 à 10 et je veux un compte à rebours par exemple 10,9,8...0.

J'ai aussi essayé ça, mais le timer n'existe pas pour le type Observables

Observable.range(10, 0).timer(1000).subscribe(x => console.log(x));

Ainsi que, qui ne produit aucune sortie.

Observable.range(10, 0).debounceTime(1000).subscribe(x => console.log(x));

De préciser j'ai besoin d'aide avec ReactiveX de RxJS mise en œuvre, pas la MircoSoft version.

OriginalL'auteur Jonathan Miles | 2016-01-21

  1. 23

    Vous étiez sur la bonne voie - votre problème est que timer n'existe pas sur le prototype (et, partant, sur la Observable.range())mais sur les Observables (voir la RxJS docs). I. e. jsbin

    const start = 10;
Rx.Observable
  .timer(100, 100) //timer(firstValueDelay, intervalBetweenValues)
  .map(i => start - i)
  .take(start + 1)
  .subscribe(i => console.log(i));

//or
Rx.Observable
  .range(0, start + 1)
  .map(i => start - i)
  .subscribe(i => console.log(i));
    Merci pour votre suggestion. Il ne le travail, il se sent juste comme il devrait y avoir des moyens plus simples de le faire avec des Observables. Idéalement, un itérateur de l'opérateur qui permet un décompte en bas plutôt que de gamme(démarrer, comte), qui ne s'incrémente.
    J'espère que quelqu'un d'autre peut fournir un moyen. Jusqu'alors: Avez-vous envisagé d'étendre le prototype de l'Observable à masquer la mise en œuvre (par exemple, comme ceci)?
    Il est un opérateur qui fait cela, generate il n'a pas été ajouté à la nouvelle projet encore.
    J'ai vu le generate fonction dans la v4, je suis surpris qu'il n'est pas en v5. Il pourrait m'offrir la fonctionnalité j'ai besoin.

    OriginalL'auteur Niklas Fasching

  2. 0

    Avec intervalle, vous permet de spécifier combien de temps une deuxième est

    const time = 5 //5 seconds
var timer$ = Rx.Observable.interval(1000) //1000 = 1 second
timer$
  .take(time)
  .map((v)=>(time-1)-v) //to reach zero
  .subscribe((v)=>console.log('Countdown', v))

    OriginalL'auteur Zafer Qadi