Created
July 19, 2022 12:43
-
-
Save pallavtrivedi03/02f9b3c4a2601e23b7947e6d54d907d3 to your computer and use it in GitHub Desktop.
Dispatch Group code used in video "Mastering Concurrency in iOS - (Part 3)"
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import UIKit | |
import Combine | |
class SplashViewController: UIViewController { | |
@IBOutlet weak var activityIndicator: UIActivityIndicatorView! | |
private var cancellables = Set<AnyCancellable>() | |
var launchDataDispatchGroup: DispatchGroup = DispatchGroup() | |
override func viewDidLoad() { | |
super.viewDidLoad() | |
DispatchQueue.global().async { [weak self] in | |
self?.getAppLaunchData() | |
} | |
} | |
func getAppLaunchData() { | |
launchDataDispatchGroup.enter() | |
NetworkManager.shared.getData(endpoint: .userPreferences, type: UserPreference.self) | |
.sink { [weak self] completion in | |
self?.launchDataDispatchGroup.leave() | |
switch completion { | |
case .failure(let err): | |
print("Error is \(err.localizedDescription)") | |
case .finished: | |
break | |
} | |
} receiveValue: { userPreferences in | |
print("Watchlists -> \(userPreferences.watchlist?.first ?? "")") | |
} | |
.store(in: &self.cancellables) | |
launchDataDispatchGroup.enter() | |
NetworkManager.shared.getData(endpoint: .appConfig, type: AppConfig.self) | |
.sink { [weak self] completion in | |
self?.launchDataDispatchGroup.leave() | |
switch completion { | |
case .failure(let err): | |
print("Error is \(err.localizedDescription)") | |
case .finished: | |
break | |
} | |
} receiveValue: { config in | |
print("Base URL -> \(config.baseURL ?? "")") | |
} | |
.store(in: &self.cancellables) | |
let waitResult: DispatchTimeoutResult = launchDataDispatchGroup.wait(timeout: .now() + .seconds(3)) | |
DispatchQueue.main.async { [weak self] in | |
switch waitResult { | |
case .success: | |
print("API calls completed before timeout") | |
case .timedOut: | |
print("APIs timed out") | |
} | |
self?.activityIndicator.stopAnimating() | |
self?.navigateToSignupVC() | |
} | |
// launchDataDispatchGroup.notify(queue: .main) { [weak self] in | |
// print("Launch calls complete, navigate to next screen") | |
// self?.activityIndicator.stopAnimating() | |
// self?.navigateToSignupVC() | |
// } | |
} | |
func navigateToSignupVC() { | |
guard let signupVC: SignupViewController = UIStoryboard(name: "Main", bundle: nil).instantiateViewController(withIdentifier: "SignupViewController") as? SignupViewController else { return } | |
UIApplication.shared.windows.first?.rootViewController = signupVC | |
UIApplication.shared.windows.first?.makeKeyAndVisible() | |
} | |
} | |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment