आरएक्सजावा - व्यवहारसुबिज

BehaviorSubject ने सबसे हाल ही में देखी गई वस्तु का उत्सर्जन किया और फिर बाद में सभी सब्सक्राइब्ड ऑब्जर्वर के लिए आइटम देखे गए।

वर्ग घोषणा

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

public final class BehaviorSubject<T>
extends Subject<T>

व्यवहार उदाहरण

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

ObservableTester.java

import io.reactivex.subjects.BehaviorSubject;
public class ObservableTester  {
   public static void main(String[] args) {   
      final StringBuilder result1 = new StringBuilder();
      final StringBuilder result2 = new StringBuilder();         
      BehaviorSubject<String> subject =  BehaviorSubject.create(); 
      subject.subscribe(value -> result1.append(value) ); 
      subject.onNext("a"); 
      subject.onNext("b"); 
      subject.onNext("c"); 
      subject.subscribe(value -> result2.append(value)); 
      subject.onNext("d"); 
      subject.onComplete();
      //Output will be abcd
      System.out.println(result1);
      //Output will be cd being BehaviorSubject 
      //(c is last item emitted before subscribe)
      System.out.println(result2);
   }
}