diff --git a/libp2p/src/main/kotlin/io/libp2p/mux/yamux/YamuxHandler.kt b/libp2p/src/main/kotlin/io/libp2p/mux/yamux/YamuxHandler.kt index b2365f27..dfaa3339 100644 --- a/libp2p/src/main/kotlin/io/libp2p/mux/yamux/YamuxHandler.kt +++ b/libp2p/src/main/kotlin/io/libp2p/mux/yamux/YamuxHandler.kt @@ -67,12 +67,12 @@ open class YamuxHandler( } } - override fun channelInactive(ctx: ChannelHandlerContext) { + override fun channelUnregistered(ctx: ChannelHandlerContext?) { sendWindowSizes.clear() sendBuffers.values.forEach { it.close() } sendBuffers.clear() receiveWindowSizes.clear() - super.channelInactive(ctx) + super.channelUnregistered(ctx) } override fun channelRead(ctx: ChannelHandlerContext, msg: Any) {