-
Observable<String> source = Observable.create(emitter -> { emitter.onNext("New~"); emitter.onNext("Hello"); emitter.onNext("World"); emitter.onError(new Throwable()); emitter.onNext("check Run? "); emitter.onComplete(); //아이템의 발행이 끝났다면 반드시 onComplete()를 호출해야 한다. onComplete 이후에는 구독자는 데이터를 받지 못한다. }); //Observable을 구독하기 위해서 subscribe()를 호출해서 Observer나 Consumer를 추가해준다. source.subscribe(this::qv, throwable -> qv("Throw~!!"));
소스파일
암호: infos
'Java' 카테고리의 다른 글
Thread IO UI 혼용 문제 증상 (0) 2022.08.07 RxJava HttpUrlConnection (0) 2022.08.07 RxJava 스케쥴러(Scheduler) 종류 (0) 2022.08.07 HttpURLConnection (0) 2022.08.07 RxJava (0) 2022.08.05 JSP에서 json 출력 (0) 2022.08.04 Gson (0) 2022.07.31 Java String 문자열 변환 UTF-8 (0) 2021.11.12