Skip to content

Commit

Permalink
Use channelUnregistered instead
Browse files Browse the repository at this point in the history
  • Loading branch information
StefanBratanov committed Sep 13, 2023
1 parent f19d86b commit b28e6cc
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions libp2p/src/main/kotlin/io/libp2p/mux/yamux/YamuxHandler.kt
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down

0 comments on commit b28e6cc

Please sign in to comment.