|
|
@@ -39,6 +39,9 @@ class InitialSettingsObservingHandler: ChannelInboundHandler, RemovableChannelHa
|
|
|
self.logger.debug("observed initial settings frame on the root stream")
|
|
|
self.connectivityStateMonitor.state = .ready
|
|
|
|
|
|
+ let remoteAddressDescription = context.channel.remoteAddress.map { "\($0)" } ?? "n/a"
|
|
|
+ self.logger.info("gRPC connection to \(remoteAddressDescription) on \(context.eventLoop) ready")
|
|
|
+
|
|
|
// We're no longer needed at this point, remove ourselves from the pipeline.
|
|
|
self.logger.debug("removing 'InitialSettingsObservingHandler' from the channel")
|
|
|
context.pipeline.removeHandler(self, promise: nil)
|