@@ -97,7 +97,7 @@ Par défault, les flux fonctionne sur le `thread` courant, c'est-à-dire le `thr
...
@@ -97,7 +97,7 @@ Par défault, les flux fonctionne sur le `thread` courant, c'est-à-dire le `thr
Nous allons étudier les émissions de flux asynchrone, une émission asynchrone arrive quand un producteur émet un flux dans un `thread` différent du `thread` qui a souscrit.
Nous allons étudier les émissions de flux asynchrone, une émission asynchrone arrive quand un producteur émet un flux dans un `thread` différent du `thread` qui a souscrit.
Les `Schedulers` de RX Java peuvent changer le comportement des `thread` d'émission et de souscription. Par exemple, nous pouvons choisir le `thread` qui émet le flux de données. Un `Scheduler` est très similaire à un `Executor` du JDK.
Les **Scheduler** de RX Java peuvent changer le comportement des `thread` d'émission et de souscription. Par exemple, nous pouvons choisir le `thread` qui émet le flux de données. Un **Scheduler** est très similaire à un `Executor` du JDK.
RX Java gére la concurrence à notre place avec deux méthodes : `subscribeOn` pour changer le `thread` de l'émetteur et `observerOn` pour changer le `thread` du consommateur.
RX Java gére la concurrence à notre place avec deux méthodes : `subscribeOn` pour changer le `thread` de l'émetteur et `observerOn` pour changer le `thread` du consommateur.
...
@@ -105,13 +105,13 @@ RX Java gére la concurrence à notre place avec deux méthodes : `subscribeOn`
...
@@ -105,13 +105,13 @@ RX Java gére la concurrence à notre place avec deux méthodes : `subscribeOn`
Testing
Testing
RX Java fournit un opérateur appelé `test` permettant de retourner une instance `TestObserver`
RX Java fournit un opérateur appelé `test` permettant de retourner une instance **TestObserver**
Cet utilitaire permet de vérifier différents types de résultat attendu
Cet utilitaire permet de vérifier différents types de résultat attendu
- Que le consommateur `Observer` a bien été souscrit
- Que le consommateur a bien été souscrit
- Que l'événement de fin du flux a bien été envoyé
- Que l'événement de fin du flux a bien été envoyé
- Que le nombre d'éléments est correct
- Que le nombre d'éléments est correct
- Que les éléments arrivent bien dans l'ordre
- Que les éléments arrivent bien dans l'ordre
RX Java fournit un deuxième utilitaire très utile pour les tests. Il s'agit de la classe `TestScheduler`, un scheduler conçu pour les tests. Il permet de contrôler l'horloge comme avancer le temps !
RX Java fournit un deuxième utilitaire très utile pour les tests. Il s'agit de la classe **TestScheduler**, un scheduler conçu pour les tests. Il permet de contrôler l'horloge comme avancer le temps !