आरएक्सजेवा 2.0 - अवलोकन करने योग्य से प्रकाशक को कैसे परिवर्तित करें

Question

आरएक्सजेवा संस्करण 2 में ऑब्जर्जेबल टू प्रकाशक को कैसे परिवर्तित करें?

पहले संस्करण में हमारे पास https://github.com/ReactiveX/RxJavaReactiveStreams प्रोजेक्ट है जो वास्तव में मुझे चाहिए। लेकिन मैं इसे RxJava 2 में कैसे कर सकता हूं?

Answer 1

निम्नलिखित कोड का उपयोग करें: backpressure को लागू नहीं करता है

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

Observable रूप में, आप backpressure रणनीति का चयन करने के लिए जब परिवर्तित करने की जरूरत है। उपलब्ध विकल्पों को देखें here।

या Flowable का उपयोग पहले स्थान पर Observable के बजाय करें। विवरण के लिए here देखें।