Remember to pass active/inactive onto next channel

swift-server-community · Dec 14, 2021 · 3f0efa5 · 3f0efa5
1 parent 7d343da
commit 3f0efa5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/Sources/MQTTNIO/ChannelHandlers/MQTTMessageHandler.swift b/Sources/MQTTNIO/ChannelHandlers/MQTTMessageHandler.swift
@@ -42,10 +42,12 @@ class MQTTMessageHandler: ChannelDuplexHandler {
 
     func channelActive(context: ChannelHandlerContext) {
         self.pingreqHandler?.start(context: context)
+        context.fireChannelActive()
     }
 
     func channelInactive(context: ChannelHandlerContext) {
         self.pingreqHandler?.stop()
+        context.fireChannelInactive()
     }
 
     func write(context: ChannelHandlerContext, data: NIOAny, promise: EventLoopPromise<Void>?) {