Skip to content

Type Method

connect(scheme:host:port:path:headers:configuration:on:onUpgrade:)

@preconcurrency static func connect(scheme: String = "ws", host: String, port: Int = 80, path: String = "/", headers: HTTPHeaders = [:], configuration: WebSocketClient.Configuration = .init(), on eventLoopGroup: any EventLoopGroup = MultiThreadedEventLoopGroup.singleton, onUpgrade: @escaping @Sendable (WebSocket) -> ()) async throws