mirror
/
swift-nio-transport-services
mirror of https://github.com/apple/swift-nio-transport-services.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Call param configurator when wrapping an existing NWConnection

This commit is contained in:
Gus Cairo 2025-04-14 14:18:30 +01:00
parent 9e6e4ed7ab
commit 08a31ceb2f
3 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Sources/NIOTransportServices/Datagram/NIOTSDatagramChannel.swift
View File

@ -140,7 +140,7 @@ internal final class NIOTSDatagramChannel: StateManagedNWConnectionChannel {
internal var allowLocalEndpointReuse = false internal var allowLocalEndpointReuse = false
internal var multipathServiceType: NWParameters.MultipathServiceType = .disabled internal var multipathServiceType: NWParameters.MultipathServiceType = .disabled
private let nwParametersConfigurator: (@Sendable (NWParameters) -> Void)? internal let nwParametersConfigurator: (@Sendable (NWParameters) -> Void)?
var parameters: NWParameters { var parameters: NWParameters {
let parameters = NWParameters(dtls: self.tlsOptions, udp: self.udpOptions) let parameters = NWParameters(dtls: self.tlsOptions, udp: self.udpOptions)

2
Sources/NIOTransportServices/NIOTSConnectionChannel.swift
View File

@ -164,7 +164,7 @@ internal final class NIOTSConnectionChannel: StateManagedNWConnectionChannel {
/// An `EventLoopPromise` that will be succeeded or failed when a connection attempt succeeds or fails. /// An `EventLoopPromise` that will be succeeded or failed when a connection attempt succeeds or fails.
internal var connectPromise: EventLoopPromise<Void>? internal var connectPromise: EventLoopPromise<Void>?
private let nwParametersConfigurator: (@Sendable (NWParameters) -> Void)? internal let nwParametersConfigurator: (@Sendable (NWParameters) -> Void)?
internal var parameters: NWParameters { internal var parameters: NWParameters {
let parameters = NWParameters(tls: self.tlsOptions, tcp: self.tcpOptions) let parameters = NWParameters(tls: self.tlsOptions, tcp: self.tcpOptions)

3
Sources/NIOTransportServices/StateManagedNWConnectionChannel.swift
View File

@ -83,6 +83,8 @@ internal protocol StateManagedNWConnectionChannel: StateManagedChannel where Act
var multipathServiceType: NWParameters.MultipathServiceType { get } var multipathServiceType: NWParameters.MultipathServiceType { get }
var nwParametersConfigurator: (@Sendable (NWParameters) -> Void)? { get }
func setChannelSpecificOption0<Option: ChannelOption>(option: Option, value: Option.Value) throws func setChannelSpecificOption0<Option: ChannelOption>(option: Option, value: Option.Value) throws
func getChannelSpecificOption0<Option: ChannelOption>(option: Option) throws -> Option.Value func getChannelSpecificOption0<Option: ChannelOption>(option: Option) throws -> Option.Value
@ -242,6 +244,7 @@ extension StateManagedNWConnectionChannel {
connection.betterPathUpdateHandler = self.betterPathHandler connection.betterPathUpdateHandler = self.betterPathHandler
connection.viabilityUpdateHandler = self.viabilityUpdateHandler connection.viabilityUpdateHandler = self.viabilityUpdateHandler
connection.pathUpdateHandler = self.pathChangedHandler(newPath:) connection.pathUpdateHandler = self.pathChangedHandler(newPath:)
self.nwParametersConfigurator?(connection.parameters)
connection.start(queue: self.connectionQueue) connection.start(queue: self.connectionQueue)
} }