Observable, Trait ( Single, Maybe, Completable ), Subject

김영민·2022년 3월 18일

iOS observable rxswift

1. Observable = Sequence

2. 비동기적

3. 일정 기간동안 계속해서 이벤트를 생성(emit)

4. 시간의 흐름에 따라서 값을 표시하는 방식

Observable의 종류

just → 원소 하나만
of → 원소 여러 개
from → 오직 배열의 형태만 가짐
empty → 즉시 종료할 수 있는 observable, 0개의 값을 리턴하고 싶은 observable 쓰고 싶을 때 사용
never → 작동은 하지만 아무 것도 방출하지 않음
range → 범위 설정
create → 직접적인 코드 구현을 통해 옵저버 메서드를 호출하여 옵저버블을 생성
deffered → observable 안에 새로운 observable들을 만들 수 있음

subscribe : 구독의 의미로 만들어진 Observable을 방출할 수 있게 해줌

observable 을 subscribe 하지 않으면 실행하지 않음 (방아쇠 역할)

dispose : subscribe를 취소

DisposeBag → 구독하고 난 뒤 disposebag에 넣고 나중에 필요할 때 한번에 방출

메모리 누수 방지에 용이

코드 예시

import UIKit
import RxSwift

print("---just---") // 원소 하나만
Observable<Int>.just(1)
    .subscribe(
        onNext: {
            print($0)
        }
    )
print("---Of---") // 원소 여러 개
Observable<Int>.of(1,2,3,4,5)
    .subscribe(
        onNext: {
            print($0)
        }
    )
print("---from---") //array 형태
Observable.from([1,2,3,4,5])
    .subscribe(
        onNext: {
            print($0)
        }
    )

Observable.range(start: 1, count: 9) //범위 
    .subscribe(
        onNext:{
            print("2 * \($0) = \(2*$0)")
        }
    )

let disposBag = DisposeBag()

// 직접적인 코드 구현을 통해 옵저버 메서드를 호출하여 옵저버블을 생성
Observable.create{ observer -> Disposable in
    observer.onNext(1)
    observer.onCompleted()
    observer.onNext(2)
    return Disposables.create()
}
.subscribe{
    print($0)
}.disposed(by: disposBag)

Trait ( Single, Maybe, Completable )

→ 좁은 범위의 Observable ( 코드 가독성을 위해 )

Single

파일 저장, 다운로드, 디스크에서 데이터 로딩에 주로 사용
네트워크 (JSONDecoding)
.success : onNext + onCompleted
asSingle 가능

Maybe

asMaybe 가능

Completable

어떠한 값도 방출하지 않는다.
동기식 연산의 성공 여부 확인

→ 유저가 작업할 동안 자료가 저장될 때, 저장이 완료되어 간단한 알림을 보내거나 에러가 발생했을 때 사용

코드 예시

Single

print("======single======")

struct SomeJSON : Decodable {
    let name: String
}

enum JSONError : Error {
    case decodingError
}

let json1 = """
    {"name":"park"}
"""

let json2 = """
    {"my_name":"Kim"}
"""

func decode(json: String) -> Single<SomeJSON> {
    Single<SomeJSON>.create { observer -> Disposable in
        guard let data = json.data(using: .utf8),
              let json = try? JSONDecoder().decode(SomeJSON.self,from: data)
        else {
            observer(.failure(JSONError.decodingError))
            return Disposables.create()
        }
        
        observer(.success(json))
        
        return Disposables.create()
    }
}

decode(json: json2)
    .subscribe{
        switch $0 {
        case .success(let json):
            print(json.name)
        case .failure(let error):
            print(error)
        }
    }.disposed(by: disposeBag)