Skip to content

Type MethodWebSocketKit

connect(to:headers:configuration:on:onUpgrade:)

@preconcurrency static func connect(to url: String, headers: HTTPHeaders = [:], configuration: WebSocketClient.Configuration = .init(), on eventLoopGroup: EventLoopGroup = MultiThreadedEventLoopGroup.singleton, onUpgrade: @Sendable @escaping (WebSocket) -> ()) async throws