import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;
public class EventExample {
public static void main(String[] args) {
Observable<Integer> observable = Observable.just(1, 2, 3, 4, 5);
Observer<Integer> observer = new Observer<Integer>() {
@Override
public void onSubscribe(Disposable d) {
System.out.println("onSubscribe");
}
@Override
public void onNext(Integer integer) {
System.out.println("onNext: " + integer);
}
@Override
public void onError(Throwable e) {
System.out.println("onError: " + e.getMessage());
}
@Override
public void onComplete() {
System.out.println("onComplete");
}
};
observable.subscribe(observer);
}
}
import io.reactivex.Observable;
public class DataTransformationExample {
public static void main(String[] args) {
Observable<Integer> observable = Observable.just(1, 2, 3, 4, 5);
observable
}
}
