RxJava - BehaviorSubject

BehaviorSubject phát ra mục gần đây nhất mà nó đã quan sát và sau đó là tất cả các mục được quan sát tiếp theo cho mỗi Người quan sát đã đăng ký.

Khai báo lớp học

Sau đây là khai báo cho io.reactivex.subjects.BehaviorSubject<T> lớp học -

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

Ví dụ về BehaviorSubject

Tạo chương trình Java sau bằng bất kỳ trình soạn thảo nào bạn chọn trong 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);
   }
}