RxSwift 개념

RxSwift 

Swift 에서 ReactiveX를 적용시켜 비동기 프로그래밍을 직관적으로 작성할 수 있도록 도와주는 라이브러리 

 

RxSwift 사용하는 이유 

downloadJson 함수를 처리한 다음에 동기적으로 해야하는 작업들이 많아진다면 콜백 지옥이 발생하게 된다. 

// escaping closure를 사용해서 결과값 전달.
func downloadJson(_ url: String, _ completion: @escaping ((String?) -> Void))? {
    DispatcheQueue.global().async {
        let url = URL(string: url)!
        let data = try! Data(contentsOf: url)
        let json = String(data: data, encoding: .utf8)
        DispatchQueue.main.async {
            completion?(json)
        }
    }
}

@IBOutlet var activityIndicator: UIActivityIndicatorView!

@IBAction func onLoad() {
    editView.text = ""
    setVisibleWithAnimation(self.activityIndicator, true)

    downloadJson(MEMBER_LIST_URL) { json in
        self.editView.text = json
        self.setVisibleWithAnimation(self.activityIndicator, false)
        
        self.downloadJson(MEMBER_LIST_URL) { json in
            self.editView.text = json
            self.setVisibleWithAnimation(self.activityIndicator, false)
          
          
          self.downloadJson(MEMBER_LIST_URL) { json in
            self.editView.text = json
            self.setVisibleWithAnimation(self.activityIndicator, false)
            
            /...
            
    	   }   
    	}
    }
}

 

 

콜백 함수를 없애기 위해 closure 대신 return 값을 받아서 처리할수 있게 변형한다면 아래와 같다. 

class 나중에생기는데이터<T> {
    private let task: (@escaping (T) -> Void) -> Void
    
    init(task: @escaping (@escaping (T) -> Void) -> Void) {
        self.task = task
    }
    
    func 나중에오면(_ f: @escaping (T) -> Void) {
        task(f)
    }
}

func downloadJson(_ url : String) -> 나중에생기는데이터<String?> {
    return 나중에생기는데이터() { f in
        let url = URL(string: url)!
        let data = try! Data(contentsof: url)
        let json = String(data: data, encoding: .utf8)
        DispatchQueue.main.async {
            f(json)
        }
    }
}

@IBOutlet var activityIndicator: UIActivityIndicatorView!

@IBAction func onLoad() {
    editView.text = ""
    setVisibleWithAnimation(self.activityIndicator, true)
    
    
    let json: 나중에생기는데이터<String?> = downloadJson(MEMBER_LIST_URL)
    
    // task 를 실행하는데, task의 인자인 f라는 함수를 넘겨주고 있다.
    // f에 들어가는 인자는 json으로 받아서 사용.
    json.나중에오면 { json in
        self.editView.text = json
        self.setVisibleWithAnimation(self.activityIndicator, false)
    }

이 아이디어로 나온게 RxSwift 인데 아래 두가지를 처리해주면 된다. 

•  비동기로 생기는 데이터를 Observable로 감써서 리턴하는 방법
• Observable 로 오는 데이터르 받아서 처리하는 방법 

 

 

Observable 을 이용해서 만들면 클로저 없이 리턴형식으로 비동기를 처리할 수 있다. 

 

1. 비동기로 생기는 데이터를 Observable로 감써서 리턴하는 방법

 

Observable의 생명주기 

 

1. create 

2. subscribe  - subscribe 가 있을 때 동작

3. onNext

4. onCompleted / onError  ( 끝 ) 

5.  Disposed   - dispose 를 동작하면 재사용 불가능 

func downloadJson(_ url: String) -> Observable<String?> {

    // 비동기로 생기는 데이터를 observable로 감싸서 return
    return Observable.create() { emitter in
        let url = URL(string: MEMBER_LIST_URL)!
        
        let task = URLSession.shaerd.dataTask(with: url) { (data, _, err) in
        
            guard err == nil else {
                emitter.onError(err!)
                return
            }
            
            if let data = data, let json = String(data: data, encoding: .utf8) {
                emitter.onNext(json)
            }
            
            emitter.onCompleted()
        }
        
        task.resume()
        
        // dispose가 불렸을 때 task를 cancel
        return Disposables.create() {
            task.cancel()
        }
    }
}

 

2. Observable 로 오는 데이터를  받아서 처리하는 방법 

@IBAction func onLoad() {
    editView.text = ""
    setVisibleWithAnimation(self.activityIndicator, true)
    

    let observable = downloadJson(MEMBER_LIST_URL)
    
    let disposable = observable.subscribe { event in
        switch event {
        case .next(let json):
           
            DispatchQueue.main.async {
                self.editView.text = json 
                self.setVisibleWithAnimation(self.activityIndicator, false)
            }
        case .error(let error):
            break
        case .completed:
            break
        }
    }
    
    disposable.dispose()
}

 

---

Reference

https://www.youtube.com/watch?v=iHKBNYMWd5I