|
@@ -130,6 +130,8 @@ extension Bolus {
|
|
|
.receive(on: DispatchQueue.global(qos: .background))
|
|
.receive(on: DispatchQueue.global(qos: .background))
|
|
|
.share()
|
|
.share()
|
|
|
.eraseToAnyPublisher()
|
|
.eraseToAnyPublisher()
|
|
|
|
|
+ registerHandlers()
|
|
|
|
|
+ registerSubscribers()
|
|
|
setupBolusStateConcurrently()
|
|
setupBolusStateConcurrently()
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -137,11 +139,6 @@ extension Bolus {
|
|
|
Task {
|
|
Task {
|
|
|
await withTaskGroup(of: Void.self) { group in
|
|
await withTaskGroup(of: Void.self) { group in
|
|
|
group.addTask {
|
|
group.addTask {
|
|
|
- // Avoid Race Condition by not executing these functions in parallel -> both are modifying the subscriptions var
|
|
|
|
|
- self.registerHandlers()
|
|
|
|
|
- self.registerSubscribers()
|
|
|
|
|
- }
|
|
|
|
|
- group.addTask {
|
|
|
|
|
self.setupGlucoseArray()
|
|
self.setupGlucoseArray()
|
|
|
}
|
|
}
|
|
|
group.addTask {
|
|
group.addTask {
|