RxJava - मेब ऑब्जर्वेबल

MayBe वर्ग आस्थगित प्रतिक्रिया का प्रतिनिधित्व करता है। MayBe अवलोकनीय या तो एकल सफल मान या कोई मान नहीं छोड़ सकता है।

वर्ग घोषणा

निम्नलिखित के लिए घोषणा है io.reactivex.Single<T> वर्ग -

public abstract class Maybe<T>
   extends Object
      implements MaybeSource<T>

मसविदा बनाना

निम्नलिखित अनुक्रमिक प्रोटोकॉल है जो मे बी ऑब्जर्वेबल संचालित करता है -

onSubscribe (onSuccess | onError | OnComplete)?

MayBe उदाहरण

C: \> RxJava, अपनी पसंद के किसी भी संपादक का उपयोग करके निम्नलिखित जावा प्रोग्राम बनाएं।

ObservableTester.java

import java.util.concurrent.TimeUnit;

import io.reactivex.Maybe;
import io.reactivex.disposables.Disposable;
import io.reactivex.observers.DisposableMaybeObserver;
import io.reactivex.schedulers.Schedulers;

public class ObservableTester {
   public static void main(String[] args) throws InterruptedException {
      //Create an observer
      Disposable disposable = Maybe.just("Hello World")
         .delay(2, TimeUnit.SECONDS, Schedulers.io())
         .subscribeWith(new DisposableMaybeObserver<String>() {
         @Override
         public void onError(Throwable e) { 
            e.printStackTrace();
         }

         @Override
         public void onSuccess(String value) {
            System.out.println(value);
         }

         @Override
         public void onComplete() {
            System.out.println("Done!");
         }
      }); 
      Thread.sleep(3000);
      //start observing
      disposable.dispose();
   }
}