Observable.create { observer in
// "Subscription Code"
// - `subscrbie()`의 호출에 의하여 호출된다.
// - subscription을 생성하고 element를 생산한다.
}
.map { ... }
.subscribe(onNext: {
// "Observation Code"
// - 방출되어진 element들을 observe한다.
})
subscribeOn()
)subscribe()
가 실행되는 thread와 동일한 thread에서 수행된다.Observable.create { observer in
// Subscription Code
}
.map { ... }
.subscribe(onNext: {
...
})
observeOn()
)Observable.create { observer in
...
}
.map { ... }
.subscribe(onNext: {
// Observation Code
})