Type Method

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

Establish a WebSocket connection.

@preconcurrency static func connect(to url: String, headers: HTTPHeaders = [:], configuration: WebSocketClient.Configuration = .init(), on eventLoopGroup: any EventLoopGroup, onUpgrade: @escaping @Sendable (WebSocket) -> ()) -> EventLoopFuture<Void>

Parameters

url: URL for the WebSocket server.
headers: Headers to send to the WebSocket server.
configuration: Configuration for the WebSocket client.
eventLoopGroup: Event loop group to be used by the WebSocket client.
onUpgrade: An escaping closure to be executed after the upgrade is completed by NIOWebSocketClientUpgrader.

Return Value

A future which completes when the connection to the WebSocket server is established.