core/mobile_nebula
1
0
Fork 1
mirror of https://github.com/DefinedNet/mobile_nebula.git synced 2025-02-15 16:25:26 +00:00
Code Issues Projects Releases Packages Wiki Activity

Use an AsyncStream of site updates to avoid concurrency warnings

Browse source
This commit is contained in:
Caleb Jasik 2025-02-12 15:05:37 -06:00
parent 275b4a50fb
commit e4940d3e3a
No known key found for this signature in database
2 changed files with 20 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
ios/Runner/AppDelegate.swift
View file

@ -25,15 +25,14 @@ func MissingArgumentError(message: String, details: Any?) -> FlutterError {
) -> Bool { ) -> Bool {
GeneratedPluginRegistrant.register(with: self) GeneratedPluginRegistrant.register(with: self)
Task.detached { Task {
await self.dnUpdater.updateAllLoop { [weak self] site in for await site in dnUpdater.siteUpdates {
self?.sites?.updateSite(site: site) self.sites?.updateSite(site: site)
// Send the refresh sites command on the main thread // Send the refresh sites command on the main thread
DispatchQueue.main.async { DispatchQueue.main.async {
// Signal to the main screen to reload // Signal to the main screen to reload
self?.ui?.invokeMethod("refreshSites", arguments: nil) self.ui?.invokeMethod("refreshSites", arguments: nil)
} }
} }
} }

18
ios/Runner/DNUpdate.swift
View file

@ -1,7 +1,7 @@
import Foundation import Foundation
import os.log import os.log
actor DNUpdater { class DNUpdater {
private let apiClient = APIClient() private let apiClient = APIClient()
private let timer = RepeatingTimer(timeInterval: 15 * 60) // 15 * 60 is 15 minutes private let timer = RepeatingTimer(timeInterval: 15 * 60) // 15 * 60 is 15 minutes
private let log = Logger(subsystem: "net.defined.mobileNebula", category: "DNUpdater") private let log = Logger(subsystem: "net.defined.mobileNebula", category: "DNUpdater")
@ -18,7 +18,7 @@ actor DNUpdater {
return return
} }
await self.updateSite(site: site, onUpdate: onUpdate) self.updateSite(site: site, onUpdate: onUpdate)
} }
} }
@ -95,6 +95,20 @@ actor DNUpdater {
} }
} }
extension DNUpdater {
// Site updates provides an async/await alternative to `.updateAllLoop` that doesn't require a sendable closure.
// https://developer.apple.com/documentation/swift/asyncstream
var siteUpdates: AsyncStream<Site> {
AsyncStream { continuation in
self.updateAllLoop(onUpdate: { site in
continuation.yield(site)
})
}
}
}
// From https://medium.com/over-engineering/a-background-repeating-timer-in-swift-412cecfd2ef9 // From https://medium.com/over-engineering/a-background-repeating-timer-in-swift-412cecfd2ef9
class RepeatingTimer { class RepeatingTimer {