RxJava 2.0 - Jak przekonwertować obserwowalne do wydawcy

Jak przekonwertować obserwowalne do wydawcy w wersji RxJava 2?RxJava 2.0 - Jak przekonwertować obserwowalne do wydawcy

W pierwszej wersji mamy projekt https://github.com/ReactiveX/RxJavaReactiveStreams, który robi dokładnie to, czego potrzebuję. Ale jak mogę to zrobić w RxJava 2?

Konwersja do postaci płynnej podczas implementacji programu Publisher. – akarnokd

Użyj następującego kodu:

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

Jak Observable nie implementuje nadciśnieniem, trzeba wybrać ciśnienie wsteczne strategię podczas konwersji. Zobacz dostępne opcje: here.

Najpierw użyj Flowable zamiast zamiast Observable. Zobacz: here, aby uzyskać szczegółowe informacje.

2017-01-13 11:59:17

Odpowiedz