func subscribe()

in AppSyncRTCSample/AppSyncRTCProvider.swift [127:153]

24 lines of code
2 McCabe index (conditional complexity)


    func subscribe() {
        os_log(#function, log: .subscription, type: .debug)
        if subscriptionConnection != nil, subscriptionItem != nil {
            unsubscribe()
        }

        let subscriptionConnection = AppSyncRTCProvider
            .makeSubscriptionConnection(using: connectionProvider)

        self.subscriptionConnection = subscriptionConnection
        DispatchQueue.global().async {
            self.subscriptionItem = subscriptionConnection.subscribe(
                requestString: self.requestString,
                variables: nil
            ) { event, item in
                OSLog.subscription.log(
                    "received event:\(event), item:\(item)",
                    log: .subscription,
                    type: .debug
                )

                DispatchQueue.main.async {
                    self.handleEvent(event: event)
                }
            }
        }
    }