Swift UI 非同期通信で取得したデータを用いて任意の処理を行いたい

Question

前提

当方Swift UIを初めて１ヶ月半程度のものです。
非同期通信で取得したデータを用いてさまざまな処理を行いたいと考えております。
現在、Web APIから２種類のjsonデータを取得するところまでは完了しております。

実現したいこと

非同期通信で２種類の[String]型のjsonデータ（eventData・eventData2）を取得し、それぞれの配列で一致するValueを新しい配列に格納しようと考えています。

発生している問題・エラーメッセージ

EventFetcherクラスで取得したjsonデータを構造体SomeStructにバインドさせたところ、データの中身が空になっており、処理を行う事ができません。

ネットで同様の処理を行おうとしている人がいないか調べたのですが、取得したjsonデータをそのままViewに表示する例は見つかるのですが、取得したjsonデータを用いて何らかの処理を行っているという例が見つからず、どのように実現させれば良いのか分からず困っております。

おそらく初歩的なところで躓いているのだと思いますが、何らかのアドバイスを頂けますと幸いです。どうぞよろしくお願い致します。

該当のソースコード

class EventFetcher: ObservableObject {
    private let urlLink = "https://api.odpt.org/api/v4/odpt:Bus?odpt:operator=odpt.Operator:Toei&acl:consumerKey=XXXX”
    private let urlLink2 = "https://api.odpt.org/api/v4/odpt:BusroutePattern?odpt:operator=odpt.Operator:Toei&acl:consumerKey=XXXX”

    @Published var eventData = [LocationData(toBusstopPole: "",odptBusroutePattern : "")]
    @Published var eventData2 = TownRankingData(busstopPoleOrder: [])

    init() {
        fetchEventData()
    }

    func fetchEventData() {
        URLSession.shared.dataTask(with: URL(string: urlLink)!) { (data, response, error) in
            guard let data = data else { return }
            let decoder: JSONDecoder = JSONDecoder()
            do {
                let searchedResultData = try decoder.decode(Array<LocationData>.self, from: data)
                DispatchQueue.main.async {
                    self.eventData = searchedResultData
                    print(self.eventData)//データが取得できていることを確認済み
                }
            } catch {
                print("json convert failed in JSONDecoder. " + error.localizedDescription)
            }
        }.resume()
        
        URLSession.shared.dataTask(with: URL(string: urlLink2)!) { (data, response, error) in
            guard let data = data else { return }
            let decoder: JSONDecoder = JSONDecoder()
            do {
                let searchedResultData = try decoder.decode([TownRankingData].self, from: data)
                DispatchQueue.main.async {
                    self.eventData2 = searchedResultData[0]
                    print(self.eventData2)//データが取得できていることを確認済み
                }
            } catch {
                print("json convert failed in JSONDecoder. " + error.localizedDescription)
            }
        }.resume()
    }
}

struct SomeStruct {
    @ObservedObject var fetcher = EventFetcher()
    var newArray: [String] = []
    init(){
        createNewArray()
    }
    mutating func createNewArray(){
        print(fetcher.eventData)//[swift_project_20221119.LocationData(toBusstopPole: "", odptBusroutePattern: "")]
        print(fetcher.eventData2) //TownRankingData(busstopPoleOrder: [])
       //一致するValueを配列に追加
         for i in fetcher.eventData2.busstopPoleOrder{
           for j in fetcher.eventData{
              if i.odptBusstopPole == j.toBusstopPole {
                  self.newArray.append(i.odptBusstopPole)
              }
           }
         }
         print(newArray)
    }
}

試したこと

EventFetcherクラスで取得したデータを処理するため、SomeStruct構造体を作成し、その中で処理を行おうとしています。

しかしながら、SomeStruct構造体にデータをバインドしたところデータが空の状態になっております。

当方は、ここでデータバインドができれば処理ができると考えておりますが、もし、このやり方自体に問題があるようでしたら、ご教示いただきたく存じます。

Answer 1

URLSession.shared.dataTaskは非同期ですので、
SomeStructのinit()が動いたタイミングではまだデータの取得が完了していないことが原因かなと思いました。

質問欄のコードのイメージを維持するとして、
修正するとしたら次のような感じになるかなと思いました。
＊SomeStructをどのように使うかまでは質問欄からは把握できなかったのですが、このままでは使いづらい状況になりそうに思いました・・
＊私自身Combineの使い方はまだまだですので至らない点もあるかもしれません・・

// @Publishedを購読するためにCombineをimportします。
import Combine
// 変化する状態を扱うためstructではなくclassに変更しました。
class SomeStruct {
    @ObservedObject var fetcher = EventFetcher()
    var newArray: [String] = []
    // 購読を解放するためのAnyCancellableを定義します。
    var cancellables = Set<AnyCancellable>()
    init(){
        createNewArray()
    }
    func createNewArray(){
        fetcher.$eventData
            .combineLatest(fetcher.$eventData2)
            .sink { (x, y) in
                // fetcher.eventDataかfetcher.eventData2が設定されるとnewArrayを作り直します。
                self.newArray.removeAll()
                //一致するValueを配列に追加
                for i in y.busstopPoleOrder{
                    for j in x{
                        if i.odptBusstopPole == j.toBusstopPole {
                           self.newArray.append(i.odptBusstopPole)
                        }
                    }
                }
                print(self.newArray) // ["toBusstopPole01", "toBusstopPole02"]
            }
            .store(in: &cancellables)
    }
}

Comments

[jun9]

xg63ex2b様　ご回答いただきありがとうございました。ご教示いただいた通り、Combineをimportし、実装を行ったところ、問題が解決しました。なかなか解決しなかったのでとても感謝してします。また、SomeStructどのように使うかについては、このclassで新たに作成した配列をViewにバインドし、表示させようと考えています。(web APIで複数のデータを取得→SomeStructでデータをもとに新たな配列を生成→Viewに表示といった流れです。）