RxJava 2.0 - Cách chuyển đổi Quan sát thành Nhà xuất bản

Question

Làm thế nào để chuyển đổi Quan sát thành Nhà xuất bản trong RxJava phiên bản 2?

Trong phiên bản đầu tiên, chúng tôi có dự án https://github.com/ReactiveX/RxJavaReactiveStreams thực hiện chính xác những gì tôi cần. Nhưng tôi có thể làm như thế nào trong RxJava 2?

Answer 1

Sử dụng đoạn mã sau:

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

Như Observable không thực hiện backpressure, bạn cần phải lựa chọn chiến lược backpressure khi chuyển đổi. Xem các lựa chọn có sẵn here.

Hoặc sử dụng Flowable thay vì Observable ngay từ đầu. Xem here để biết chi tiết.