Start pingreq handler on handler added

adam-fowler · adam-fowler · commit 55da431a0f59 · 2021-11-22T18:21:03.000Z
diff --git a/Sources/MQTTNIO/ChannelHandlers/MQTTMessageHandler.swift b/Sources/MQTTNIO/ChannelHandlers/MQTTMessageHandler.swift
@@ -34,14 +34,12 @@ class MQTTMessageHandler: ChannelDuplexHandler {
         self.decoder = .init(.init(version: client.configuration.version))
     }
 
-    func channelActive(context: ChannelHandlerContext) {
+    func handlerAdded(context: ChannelHandlerContext) {
         self.pingreqHandler?.start(context: context)
-        context.fireChannelActive()
     }
 
-    func channelInactive(context: ChannelHandlerContext) {
+    func handlerRemoved(context: ChannelHandlerContext) {
         self.pingreqHandler?.stop()
-        context.fireChannelInactive()
     }
 
     func write(context: ChannelHandlerContext, data: NIOAny, promise: EventLoopPromise<Void>?) {

Original file line number	Diff line number	Diff line change
`@@ -34,14 +34,12 @@ class MQTTMessageHandler: ChannelDuplexHandler {`
`34`	`34`	`self.decoder = .init(.init(version: client.configuration.version))`
`35`	`35`	`}`
`36`	`36`
`37`		`- func channelActive(context: ChannelHandlerContext) {`
	`37`	`+ func handlerAdded(context: ChannelHandlerContext) {`
`38`	`38`	`self.pingreqHandler?.start(context: context)`
`39`		`- context.fireChannelActive()`
`40`	`39`	`}`
`41`	`40`
`42`		`- func channelInactive(context: ChannelHandlerContext) {`
	`41`	`+ func handlerRemoved(context: ChannelHandlerContext) {`
`43`	`42`	`self.pingreqHandler?.stop()`
`44`		`- context.fireChannelInactive()`
`45`	`43`	`}`
`46`	`44`
`47`	`45`	`func write(context: ChannelHandlerContext, data: NIOAny, promise: EventLoopPromise<Void>?) {`