RxJava2Example

• Source

  • Part 1
  • Part 2

• Implementation

implementation 'io.reactivex.rxjava2:rxandroid:2.1.1'
implementation 'io.reactivex.rxjava2:rxjava:2.2.9'

• Example 1

StringBuilderstr = newStringBuilder();
Observable<String> observaBLE = Observable.create(newObservableOnSubscribe<String>() {
@Overridepublicvoidsubscribe(@NonNullObservableEmitter<String> emitter) throwsException {
str.append("2. Value Default").append("\n");
setView();
emitter.onNext("Hello Zein");
// emitter.onNext(null); // contoh erroremitter.onComplete();
}
});
Observer<String> obserVER = newObserver<String>() {
@OverridepublicvoidonSubscribe(@NonNullDisposabled) {
str.append("1. Loading onSubscribe").append("\n");
setView();
}
@OverridepublicvoidonNext(@NonNullStrings) {
str.append("3. onNext ").append(s).append("\n");
setView();
}
@OverridepublicvoidonError(@NonNullThrowablee) {
str.append("3. onError ").append(e.getMessage()).append("\n");
setView();
}
@OverridepublicvoidonComplete() {
str.append("4. Loading onComplete").append("\n");
setView();
}
};
observaBLE.subscribe(obserVER);

• Example 2

StringBuilderstr = newStringBuilder();
Observable.create(newObservableOnSubscribe<String>() {
@Overridepublicvoidsubscribe(@NonNullObservableEmitter<String> emitter) throwsException {
str.append("2. Value Default").append("\n");
setView();
emitter.onNext("Hello Zein");
// emitter.onNext(null); // contoh erroremitter.onComplete();
}
}).subscribe(newObserver<String>() {
@OverridepublicvoidonSubscribe(@NonNullDisposabled) {
str.append("1. Loading onSubscribe").append("\n");
setView();
}
@OverridepublicvoidonNext(@NonNullStrings) {
str.append("3. onNext ").append(s).append("\n");
setView();
}
@OverridepublicvoidonError(@NonNullThrowablee) {
str.append("3. onError ").append(e.getMessage()).append("\n");
setView();
}
@OverridepublicvoidonComplete() {
str.append("4. Loading onComplete").append("\n");
setView();
}
});

• setview();

privatevoidsetView(){
TextViewtv= findViewById(R.id.tv);
tv.setText(str.toString());
}

• Preview

---

FullCode MainActivity

---

Copyright 2020 M. Fadli Zein