resolve comments

aws-amplify · May 13, 2024 · 9df1524 · 9df1524
1 parent eefd597
commit 9df1524
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/Amplify/Core/Support/AmplifyAsyncThrowingSequence.swift b/Amplify/Core/Support/AmplifyAsyncThrowingSequence.swift
@@ -6,7 +6,6 @@
 //
 
 import Foundation
-import Combine
 
 public typealias WeakAmplifyAsyncThrowingSequenceRef<Element> = WeakRef<AmplifyAsyncThrowingSequence<Element>>
 

diff --git a/AmplifyPlugins/API/Sources/AWSAPIPlugin/Operation/AWSGraphQLSubscriptionTaskRunner.swift b/AmplifyPlugins/API/Sources/AWSAPIPlugin/Operation/AWSGraphQLSubscriptionTaskRunner.swift
@@ -114,8 +114,8 @@ public class AWSGraphQLSubscriptionTaskRunner<R: Decodable>: InternalTaskRunner,
             self.subscription = try await appSyncClient?.subscribe(
                 id: subscriptionId,
                 query: encodeRequest(query: request.document, variables: request.variables)
-            ).sink(receiveValue: { event in
-                self.onAsyncSubscriptionEvent(event: event)
+            ).sink(receiveValue: { [weak self] event in
+                self?.onAsyncSubscriptionEvent(event: event)
             })
         } catch {
             let error = APIError.operationError("Unable to get connection for api \(endpointConfig.name)", "", error)
-Original file line number
+Diff line change
@@ Expand Up / @@ -6,7 +6,6 @@ @@
     //
     import Foundation
-    import Combine
     public typealias WeakAmplifyAsyncThrowingSequenceRef<Element> = WeakRef<AmplifyAsyncThrowingSequence<Element>>
@@ Expand Down @@