Hajime !

Asynchrone

Le monde est asynchrone

Le monde est asynchrone

Reactive manifesto

Message driven

Resilient

Elastic

Responsive

Programmation reactive

Comment modéliser un flux de données ?

Marble diagrams

Stream simple

Stream avec erreur

Stream avec opération

Et en RX ?

Observable.of('A','B','C')
	  .map(value => value.toLowerCase())
   	  .subscribe(value => console.log(value));

Result

 'a'
 'b'
 'c'

Classe principales

• Observable auquel on souscrit
• Observer object qui souscrit à l'Observable
  • onNext()
  • onCompleted()
  • onError()
• Subscription permet de gérer les sousscription

Mais pourquoi faire ça ?

• Gérer des évenemements multiples
• Avoir une approche déclarative
• Promouvoir la programmation fonctionnelle
• Eviter le callback hell

Mais à quel point est-ce puissant ?

Example 1 : Afficher une horloge

@Component({
  selector: 'async-observable-pipe',
  template: '<div>Time: {{ time | async }}</div>'
  })

export class AsyncExample {
  time = new Observable((observer) => {
    setInterval(() =>{
      return observer.next(new Date().toString()), 1000);
    }
   });
}

eazy peazy

Example 2 : Gérer les doubles clicks

let clickStream 
	= Rx.Observable.fromEvent(document, 'click');

clickStream
  .buffer(clickStream.debounce(250))
  .map(list => list.length)
  .filter(x => x === 2)
  .subscribe(() => console.log('doubleclick'))

eazy peazy

Conseils

• Distinguez Rx des autres API de stream
• Peut devenir complexe → expérimentez !
• N'ayez pas peur de la doc de Rx ! (example exhaust)
  • reactive.how
• Pensez stream processing !

Système réactif

Pourquoi ?

Kezako?

Kezako?

Pattern reactor

NE JAMAIS BLOQUER L'EVENT LOOP!

Implémentation front : Redux

Intérêts

Intérêts

• Simplicité de l'état de l'application
• Possibilité de rejouer les évènements
• Utilisation de fonctions pures pour la logique métier

Implémentation back: Vertx

Intérêts

• montée en charge
• souplesse architecturale

REX/Conseils

• NE JAMAIS BLOQUER L'EVENT LOOP!
• Attention aux backpressures
• Garder un œil sur les threads utilisés
• Les tests d'intégration

Conclusion

• Changement fort de paradigme
• S'intégre parfaitement avec CQRS/ES
• Bon levier technique pour l'architecture hexagonale
• Outillage varié et « à la mode » et très puissants
  • Message broker
  • Base de données NoSQL
  • …

Liens intéressants

• Des vieilles bases d'unix à la hype reactive actuelle
• Documentation de Vertx code
• La révolution réactive !
• Multitâche ou réactif
• Comprendre les opérateurs Rx

References

Les docs
• Doc RXJS 1 (en beta)
• Doc RXJS 2, un peu plus complète mais pas pratique à utiliser
• Doc RX, moins spécifique que les précedante
• Example du bouble click
• Example du pipe de l'horloge

Pour aller plus loin

• Functional Reactive Programming
• Système à Actor (comme Akka ou Erlang)
• Green thread (go)

Questions ?