diff --git a/transport/internet/kcp/connection.go b/transport/internet/kcp/connection.go
index 367244812..3913cbf9f 100644
--- a/transport/internet/kcp/connection.go
+++ b/transport/internet/kcp/connection.go
@@ -517,6 +517,10 @@ func (v *Connection) Input(segments []Segment) {
 					v.SetState(StateTerminated)
 				}
 			}
+			if seg.Option == SegmentOptionClose || seg.Command() == CommandTerminate {
+				v.OnDataInput()
+				v.OnDataOutput()
+			}
 			v.sendingWorker.ProcessReceivingNext(seg.ReceivinNext)
 			v.receivingWorker.ProcessSendingNext(seg.SendingNext)
 			v.roundTrip.UpdatePeerRTO(seg.PeerRTO, current)