RxJava-ReplaySubject
ReplaySubject는 현재 및 후기 관찰자에게 이벤트 / 항목을 재생합니다.
클래스 선언
다음은에 대한 선언입니다. io.reactivex.subjects.ReplaySubject<T> 클래스-
public final class ReplaySubject<T>
extends Subject<T>
ReplaySubject 예
C : \> RxJava에서 원하는 편집기를 사용하여 다음 Java 프로그램을 만듭니다.
ObservableTester.java
import io.reactivex.subjects.ReplaySubject;
public class ObservableTester {
public static void main(String[] args) {
final StringBuilder result1 = new StringBuilder();
final StringBuilder result2 = new StringBuilder();
ReplaySubject<String> subject = ReplaySubject.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 abcd being ReplaySubject
//as ReplaySubject emits all the items
System.out.println(result2);
}
}
결과 확인
다음을 사용하여 클래스 컴파일 javac 다음과 같이 컴파일러-
C:\RxJava>javac ObservableTester.java
이제 다음과 같이 ObservableTester를 실행하십시오.
C:\RxJava>java ObservableTester
다음 출력을 생성해야합니다.
abcd
abcd