[Rxjava Demo] rxjava #java #rxjava #reactive

demo.java

import io.reactivex.rxjava3.core.Observable;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Main {
    public static ExecutorService pool = Executors.newFixedThreadPool(1);
    public static Observable<Integer> createObservable() {
        return Observable.create(sub -> {
            pool.submit(() -> {
                int i = 0;
                while (true) {
                    try {
                        sub.onNext(i);
                        i += 1;
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            });
        });
    }

    public static void main(String[] args) {
        Main.createObservable()
                .skip(2)
                .take(5)
                .subscribe(System.out::println);
        pool.shutdown();
    }
}