나만을 위한 블로그

이전 포스팅에서 Observable에 대해 살펴봤으니 이 포스팅에선 관련된 예제를 확인한다 먼저 Cold Observable의 예제다. import io.reactivex.rxjava3.core.Observable; import java.util.concurrent.TimeUnit; public class Main { public static void main(String[] args) { coldObservableText(); } public static void coldObservableText() { Observable observable = Observable.interval(1, TimeUnit.SECONDS); observable.subscribe(item -> System.out.printl..