Sendable

arkavo-org · Oct 8, 2024 · 04e4fc4 · 04e4fc4
1 parent 2cd8ac5
commit 04e4fc4
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/OpenTDFKit/BinaryParser.swift b/OpenTDFKit/BinaryParser.swift
@@ -138,7 +138,7 @@ public class BinaryParser {
     }
 
     func readPolicyBinding(bindingMode: PolicyBindingConfig) -> Data? {
-        var bindingSize
+        let bindingSize
 //        print("bindingMode", bindingMode)
             = if bindingMode.ecdsaBinding
         {

diff --git a/OpenTDFKit/KASRest.swift b/OpenTDFKit/KASRest.swift
@@ -9,7 +9,7 @@ class KASRest {
         self.apiKey = apiKey
     }
 
-    public func rewrap(key: String, completion: @escaping (Result<String, Error>) -> Void) {
+    public func rewrap(key: String, completion: @escaping @Sendable (Result<String, Error>) -> Void) {
         guard let url = URL(string: "\(baseURL)/rewrap") else {
             completion(.failure(NSError(domain: "KASClient", code: -1, userInfo: [NSLocalizedDescriptionKey: "Invalid URL"])))
             return

diff --git a/OpenTDFKit/KASWebSocket.swift b/OpenTDFKit/KASWebSocket.swift
@@ -18,7 +18,7 @@ extension WebSocketConnectionState: CustomStringConvertible {
     }
 }
 
-public class KASWebSocket {
+public class KASWebSocket: @unchecked Sendable {
     private var webSocketTask: URLSessionWebSocketTask?
     private var urlSession: URLSession?
     private let myPrivateKey: P256.KeyAgreement.PrivateKey!
@@ -54,7 +54,7 @@ public class KASWebSocket {
         customMessageCallback = callback
     }
 
-    public func sendCustomMessage(_ message: Data, completion: @escaping (Error?) -> Void) {
+    public func sendCustomMessage(_ message: Data, completion: @Sendable @escaping (Error?) -> Void) {
         let task = URLSessionWebSocketTask.Message.data(message)
         webSocketTask?.send(task) { error in
             if let error {
@@ -276,7 +276,7 @@ public class KASWebSocket {
         }
     }
 
-    public func sendPing(completionHandler: @escaping (Error?) -> Void) {
+    public func sendPing(completionHandler: @escaping @Sendable (Error?) -> Void) {
         webSocketTask?.sendPing { error in
             if let error {
                 print("Error sending ping: \(error)")