2024-08-12

[minjae-L]

Rx + URLSession 을 사용하여 데이터 통신 리턴 형식이 Single이다. 공공 데이터 포털에서 한번에 날씨의 모든 정보를 불러오려면 두번 걸쳐서 데이터를 받아와야한다.

• 현재 구현방식

  for i in 1...2 {
          APIManager.shared.fetchData(nx: nx, ny: ny, page: i)
              .subscribe {[weak self] event in
                  switch event {
                  case .success(let data):
                      self?.convertDataFromCategory(response: data)
                  case .failure(let error):
                      print(error)
                  }
              }
              .disposed(by: disposeBag)
      }

Single로 반환하되 매개변수를 Page번호로 1번 2번 모두 받게끔 반복문으로 진행 Single이 비록 Success 혹은 Fail 한번만 이벤트 방출후 자동 종료되지만 반복문으로 진행하기에 뭔가.. 괜찮은 방식이 아닌것 같다.

• 바꾸고자 하는 형식 Single은 딱 한번만 이벤트 방출하므로 이 메서드는 냅두고 Observable을 asSingle을 통해 변환하여 두개의 이벤트를 전송하는 방법? Observable의 연산자중 두개의 Observable을 합치는 merge나 zip을 이용하여 1번페이지, 2번페이지의 데이터를 합치는 방법?

[minjae-L]

두개의 Single을 zip연산자를 사용하여 결합한 후 이벤트 방출하는 방식

let single1 = APIManager.shared.fetchData(nx: location.x, ny: location.y, page: 1)
let single2 = APIManager.shared.fetchData(nx: location.x, ny: location.y, page: 2)

let zippedSingle = Single.zip(single1, single2)
          zippedSingle
                .subscribe {[weak self] event in
                    switch event {
                    case .success((let result1, let result2)):
                        switch result1 {
                        case .success(let data):
                            self?.convertDataFromCategory(response: data)
                        case .failure(let error):
                            print("page 1 error:\(error)")
                        }
                        switch result2 {
                        case .success(let data):
                            self?.convertDataFromCategory(response: data)
                        case .failure(let error):
                            print("page 2 error:\(error)")
                        }
                    case .failure(let error):
                        print("zipped single fail\(error)")
                    }
                }