일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | |||
5 | 6 | 7 | 8 | 9 | 10 | 11 |
12 | 13 | 14 | 15 | 16 | 17 | 18 |
19 | 20 | 21 | 22 | 23 | 24 | 25 |
26 | 27 | 28 | 29 | 30 | 31 |
- 주 4일 근무제
- 주 4일 근무제 경험담
- supabase storage feature not enabled for this tenant
- no such module '__ObjC'
- 소개팅앱 만들기 flutter
- 로컬 서버 접속
- supabase edge function deploy error supabaseurl is required
- Firebase authentication apple login 최신
- Supabase edge function insert data
- Android apple login 인증서 설정
- invite user for supabase project
- 주 4일 근무제 log
- Firebase authentication android apple login setting
- Spring google SMTP settings
- stable-diffusion-webui local 네트워크에서 접속
- 소개팅앱 만들기
- Spring boot swagger blank screen
- supabase edge function deploy error
- stable-diffusion-webui local 접속
- Spring LocalDateTime response array
- DT_TOOLCHAIN_DIR cannot be used
- Stomp socket connection event
- Firebase authentication apple login
- Android apple login identifier
- Android apple login
- 소개팅앱 만들기 stomp
- Supabase edge function
- supabase storage public url not working
- Firebase authentication android apple login
- Stomp user connection event
- Today
- Total
꿀맛코딩
observable.from and observable.just 본문
observable.from() 과 observable.just() 의 차이에 대해서 알아보자
observable.from은 내부의 아이템들의 요소를 각각 배출하고
observable.just는 내부의 아이템들을 각각 배출하는데
알기쉽게 결과로 보면 다음과 같다.
먼저 from 코드와 결과 이다.
코드
val fromObserver = object : Observer<String> {
override fun onComplete() {
println("onComplete")
}
override fun onSubscribe(d: Disposable) {
println("New Subscribtion = ${d}")
}
override fun onNext(item: String) {
println("Next = $item")
}
override fun onError(e: Throwable) {
println("Error Occured ${e.message}")
}
}
fun simpleObservableFrom() {
val list = listOf("String1", "String2", "String3", "String4")
val observableFromIterable = Observable.fromIterable(list)
observableFromIterable.subscribe(fromObserver)
}
결과
다음은 just의 코드와 결과 이다.
코드
val justObserver = object : Observer<List<String>> {
override fun onComplete() {
println("onComplete")
}
override fun onSubscribe(d: Disposable) {
println("New Subscribtion = ${d}")
}
override fun onNext(item: List<String>) {
println("Next = $item")
}
override fun onError(e: Throwable) {
println("Error Occured ${e.message}")
}
}
fun simpleObservableJust() {
val list = listOf("String1", "String2", "String3", "String4")
val observableFromIterable = Observable.just(list)
observableFromIterable.subscribe(justObserver)
}
결과
참고로 from을 설명 했는데 예제에서 fromIterable 을 사용한 이유는
RxKotlin 1에서는 Observerble.from을 사용했었지만, RxKotlin 2.0에서는 연산자 오버로드로
fromFuture, fromIterable, fromCallable 등과 같이 접미사가 추가 되었다.
'공부방 > RxKotlin' 카테고리의 다른 글
What is BackPressure? (BackPressure 란?) (0) | 2019.07.25 |
---|---|
What is ConnectableObservable? (0) | 2019.07.23 |
cold observable and hot observable (0) | 2019.07.23 |
What is Observable? (0) | 2019.07.23 |
Simple Observable (0) | 2019.07.23 |