diff --git a/app/proxyman/inbound/worker.go b/app/proxyman/inbound/worker.go index 2a2793eb..13ef405f 100644 --- a/app/proxyman/inbound/worker.go +++ b/app/proxyman/inbound/worker.go @@ -187,6 +187,15 @@ func (c *udpConn) Write(buf []byte) (int, error) { return n, err } +// Implements buf.ActivityNotifiable +func (c *udpConn) NotifyActivity() error { + if c.done.Done() { + return newError("connection is already closed") + } + c.updateActivity() + return nil +} + func (c *udpConn) Close() error { common.Must(c.done.Close()) common.Must(common.Close(c.writer))