RxJava 2.0 - Comment convertir les fichiers Observable en Publisher

Question

Comment convertir les fichiers Observable en Publisher dans RxJava version 2?

Dans la première version, nous avons le projet https://github.com/ReactiveX/RxJavaReactiveStreams qui fait exactement ce dont j'ai besoin. Mais comment puis-je le faire dans RxJava 2?

Answer 1

Utilisez le code suivant:

Publisher publisher = observable.toFlowable(BackpressureStrategy.XXX); 

Comme Observable ne met pas en œuvre contrepression, vous devez sélectionner la stratégie de contre-pression lors de la conversion. Voir les choix disponibles here. En premier lieu, utiliser Flowable au lieu de Observable. Voir here pour plus de détails.