feat: add support for returning a value to TaskQueue.sync (#2387)

ameter · web-flow · commit a096aee6f24d · 2022-10-04T14:25:20.000-06:00
diff --git a/Amplify/Core/Support/TaskQueue.swift b/Amplify/Core/Support/TaskQueue.swift
@@ -12,11 +12,13 @@ public actor TaskQueue<Success> {
     
     public init() {}
 
-    public func sync(block: @Sendable @escaping () async throws -> Success) rethrows {
-        previousTask = Task { [previousTask] in
+    public func sync(block: @Sendable @escaping () async throws -> Success) async throws -> Success {
+        let currentTask = Task { [previousTask] in
             _ = await previousTask?.result
             return try await block()
         }
+        previousTask = currentTask
+        return try await currentTask.value
     }
 
     public nonisolated func async(block: @Sendable @escaping () async throws -> Success) rethrows {

Original file line number	Diff line number	Diff line change
`@@ -12,11 +12,13 @@ public actor TaskQueue<Success> {`
`12`	`12`
`13`	`13`	`public init() {}`
`14`	`14`
`15`		`- public func sync(block: @Sendable @escaping () async throws -> Success) rethrows {`
`16`		`- previousTask = Task { [previousTask] in`
	`15`	`+ public func sync(block: @Sendable @escaping () async throws -> Success) async throws -> Success {`
	`16`	`+ let currentTask = Task { [previousTask] in`
`17`	`17`	`_ = await previousTask?.result`
`18`	`18`	`return try await block()`
`19`	`19`	`}`
	`20`	`+ previousTask = currentTask`
	`21`	`+ return try await currentTask.value`
`20`	`22`	`}`
`21`	`23`
`22`	`24`	`public nonisolated func async(block: @Sendable @escaping () async throws -> Success) rethrows {`