RxJava-AsyncSubject

AsyncSubject는 완료 이벤트 또는 수신 된 오류가 뒤 따르는 유일한 마지막 값을 관찰자에게 내 보냅니다.

클래스 선언

다음은에 대한 선언입니다. io.reactivex.subjects.AsyncSubject<T> 클래스-

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

AsyncSubject 예

C : \> RxJava에서 원하는 편집기를 사용하여 다음 Java 프로그램을 만듭니다.

ObservableTester.java

import io.reactivex.subjects. AsyncSubject;
public class ObservableTester  {
   public static void main(String[] args) {   
      final StringBuilder result1 = new StringBuilder();
      final StringBuilder result2 = new StringBuilder();         

      AsyncSubject<String> subject =  AsyncSubject.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 d being the last item emitted
      System.out.println(result1);
      //Output will be d being the last item emitted     
      System.out.println(result2);
   }
}