Revert "Add Sendable conformances to WebsocketKit (#131)" (#135)

This reverts commit c2e0aa4.

.github/workflows/test.yml

@@ -5,7 +5,9 @@ concurrency:
 on:
   pull_request: { types: [opened, reopened, synchronize, ready_for_review] }
   push: { branches: [ main ] }
+
 jobs:
+
   vapor-integration:
     if: ${{ !(github.event.pull_request.draft || false) }}
     runs-on: ubuntu-latest

.gitignore

@@ -5,4 +5,3 @@
 DerivedData
 .swiftpm
 Package.resolved
-.devcontainer/

Package.swift

@@ -16,8 +16,8 @@ let package = Package(
         .package(url: "https://github.com/apple/swift-nio.git", from: "2.53.0"),
         .package(url: "https://github.com/apple/swift-nio-extras.git", from: "1.16.0"),
         .package(url: "https://github.com/apple/swift-nio-ssl.git", from: "2.24.0"),
-        .package(url: "https://github.com/apple/swift-nio-transport-services.git", from: "1.16.0"),
-        .package(url: "https://github.com/apple/swift-atomics.git", from: "1.1.0"),
+        .package(url: "https://github.com/apple/swift-nio-transport-services.git", from: "1.11.4"),
+        .package(url: "https://github.com/apple/swift-atomics.git", from: "1.0.2"),
     ],
     targets: [
         .target(name: "WebSocketKit", dependencies: [

Sources/WebSocketKit/Concurrency/WebSocket+Concurrency.swift

@@ -40,42 +40,34 @@ extension WebSocket {
         try await close(code: code).get()
     }
 
-    public func onText(_ callback: @Sendable @escaping (WebSocket, String) async -> ()) {
-        self.eventLoop.execute {
-            self.onText { socket, text in
-                Task {
-                    await callback(socket, text)
-                }
+    public func onText(_ callback: @escaping (WebSocket, String) async -> ()) {
+        onText { socket, text in
+            Task {
+                await callback(socket, text)
             }
         }
     }
 
-    public func onBinary(_ callback: @Sendable @escaping (WebSocket, ByteBuffer) async -> ()) {
-        self.eventLoop.execute {
-            self.onBinary { socket, binary in
-                Task {
-                    await callback(socket, binary)
-                }
+    public func onBinary(_ callback: @escaping (WebSocket, ByteBuffer) async -> ()) {
+        onBinary { socket, binary in
+            Task {
+                await callback(socket, binary)
             }
         }
     }
 
-    public func onPong(_ callback: @Sendable @escaping (WebSocket) async -> ()) {
-        self.eventLoop.execute {
-            self.onPong { socket in
-                Task {
-                    await callback(socket)
-                }
+    public func onPong(_ callback: @escaping (WebSocket) async -> ()) {
+        onPong { socket in
+            Task {
+                await callback(socket)
             }
         }
     }
 
-    public func onPing(_ callback: @Sendable @escaping (WebSocket) async -> ()) {
-        self.eventLoop.execute {
-            self.onPing { socket in
-                Task {
-                    await callback(socket)
-                }
+    public func onPing(_ callback: @escaping (WebSocket) async -> ()) {
+        onPing { socket in
+            Task {
+                await callback(socket)
             }
         }
     }
@@ -85,7 +77,7 @@ extension WebSocket {
         headers: HTTPHeaders = [:],
         configuration: WebSocketClient.Configuration = .init(),
         on eventLoopGroup: EventLoopGroup,
-        onUpgrade: @Sendable @escaping (WebSocket) async -> ()
+        onUpgrade: @escaping (WebSocket) async -> ()
     ) async throws {
         return try await self.connect(
             to: url,
@@ -105,7 +97,7 @@ extension WebSocket {
         headers: HTTPHeaders = [:],
         configuration: WebSocketClient.Configuration = .init(),
         on eventLoopGroup: EventLoopGroup,
-        onUpgrade: @Sendable @escaping (WebSocket) async -> ()
+        onUpgrade: @escaping (WebSocket) async -> ()
     ) async throws {
         return try await self.connect(
             to: url,
@@ -129,7 +121,7 @@ extension WebSocket {
         headers: HTTPHeaders = [:],
         configuration: WebSocketClient.Configuration = .init(),
         on eventLoopGroup: EventLoopGroup,
-        onUpgrade: @Sendable @escaping (WebSocket) async -> ()
+        onUpgrade: @escaping (WebSocket) async -> ()
     ) async throws {
         return try await self.connect(
             scheme: scheme,

Sources/WebSocketKit/Exports.swift

@@ -6,7 +6,9 @@
 @_documentation(visibility: internal) @_exported import protocol NIOCore.EventLoopGroup
 @_documentation(visibility: internal) @_exported import struct NIOCore.EventLoopPromise
 @_documentation(visibility: internal) @_exported import class NIOCore.EventLoopFuture
+
 @_documentation(visibility: internal) @_exported import struct NIOHTTP1.HTTPHeaders
+
 @_documentation(visibility: internal) @_exported import struct Foundation.URL
 
 #else
@@ -17,7 +19,9 @@
 @_exported import protocol NIOCore.EventLoopGroup
 @_exported import struct NIOCore.EventLoopPromise
 @_exported import class NIOCore.EventLoopFuture
+
 @_exported import struct NIOHTTP1.HTTPHeaders
+
 @_exported import struct Foundation.URL
 
 #endif

Sources/WebSocketKit/WebSocket+Connect.swift

@@ -17,7 +17,7 @@ extension WebSocket {
         headers: HTTPHeaders = [:],
         configuration: WebSocketClient.Configuration = .init(),
         on eventLoopGroup: EventLoopGroup,
-        onUpgrade: @Sendable @escaping (WebSocket) -> ()
+        onUpgrade: @escaping (WebSocket) -> ()
     ) -> EventLoopFuture<Void> {
         guard let url = URL(string: url) else {
             return eventLoopGroup.any().makeFailedFuture(WebSocketClient.Error.invalidURL)
@@ -45,7 +45,7 @@ extension WebSocket {
         headers: HTTPHeaders = [:],
         configuration: WebSocketClient.Configuration = .init(),
         on eventLoopGroup: EventLoopGroup,
-        onUpgrade: @Sendable @escaping (WebSocket) -> ()
+        onUpgrade: @escaping (WebSocket) -> ()
     ) -> EventLoopFuture<Void> {
         let scheme = url.scheme ?? "ws"
         return self.connect(
@@ -83,7 +83,7 @@ extension WebSocket {
         headers: HTTPHeaders = [:],
         configuration: WebSocketClient.Configuration = .init(),
         on eventLoopGroup: EventLoopGroup,
-        onUpgrade: @Sendable @escaping (WebSocket) -> ()
+        onUpgrade: @escaping (WebSocket) -> ()
     ) -> EventLoopFuture<Void> {
         return WebSocketClient(
             eventLoopGroupProvider: .shared(eventLoopGroup),
@@ -129,7 +129,7 @@ extension WebSocket {
         proxyConnectDeadline: NIODeadline = NIODeadline.distantFuture,
         configuration: WebSocketClient.Configuration = .init(),
         on eventLoopGroup: EventLoopGroup,
-        onUpgrade: @Sendable @escaping (WebSocket) -> ()
+        onUpgrade: @escaping (WebSocket) -> ()
     ) -> EventLoopFuture<Void> {
         return WebSocketClient(
             eventLoopGroupProvider: .shared(eventLoopGroup),
@@ -171,7 +171,7 @@ extension WebSocket {
         proxyConnectDeadline: NIODeadline = NIODeadline.distantFuture,
         configuration: WebSocketClient.Configuration = .init(),
         on eventLoopGroup: EventLoopGroup,
-        onUpgrade: @Sendable @escaping (WebSocket) -> ()
+        onUpgrade: @escaping (WebSocket) -> ()
     ) -> EventLoopFuture<Void> {
         guard let url = URL(string: url) else {
             return eventLoopGroup.any().makeFailedFuture(WebSocketClient.Error.invalidURL)