// 오로지 1(Int 타입)만을 방출
let observable = Observable<Int>.just(1)
//observable 구독
observable.subscribe(
onNext: { data in
print(data) // 1
},
onError: { error in
print(error) // error 시 error코드 방출 후 종료
},
onCompleted: {
print("completed") // 성공적으로 완료되면 무엇도 방출하지 않고 종료
},
onDisposed: {
print("dispose done") // 종료 후 disposed
}
)
//위 코드와 같은 맥락의 코드
let observable = Observable<Int>.just(1)
var disposeBag = DisposeBag()
observable.subscribe { event in
switch event {
case .next(let value):
print(value)
case .error(let error):
print(error)
case .completed:
print("completed")
}
}
.disposed(by: disposeBag)
- Cold Observable 형태 구독하는 방법 중 하나.