RxJava - BehaviorSubject
BehaviorSubject emite el elemento más reciente que ha observado y luego todos los elementos observados subsiguientes a cada observador suscrito.
Declaración de clase
A continuación se muestra la declaración de io.reactivex.subjects.BehaviorSubject<T> clase -
public final class BehaviorSubject<T>
extends Subject<T>
BehaviorSubject Ejemplo
Cree el siguiente programa Java utilizando cualquier editor de su elección en, digamos, 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);
}
}
Verificar el resultado
Compila la clase usando javac compilador de la siguiente manera:
C:\RxJava>javac ObservableTester.java
Ahora ejecute ObservableTester de la siguiente manera:
C:\RxJava>java ObservableTester
Debería producir el siguiente resultado:
abcd
cd