diff --git a/ruoyi-common/ruoyi-common-sse/src/main/java/org/dromara/common/sse/core/SseEmitterDelayed.java b/ruoyi-common/ruoyi-common-sse/src/main/java/org/dromara/common/sse/core/SseEmitterDelayed.java index cb9ad4d62..fa8f3368b 100644 --- a/ruoyi-common/ruoyi-common-sse/src/main/java/org/dromara/common/sse/core/SseEmitterDelayed.java +++ b/ruoyi-common/ruoyi-common-sse/src/main/java/org/dromara/common/sse/core/SseEmitterDelayed.java @@ -60,6 +60,12 @@ public class SseEmitterDelayed implements Delayed { this.expireAt = Instant.now().toEpochMilli() + unit.toMillis(delay); } + /** + * 续期当前延迟任务的到期时间 + * + * @param delay 延迟时长(例如 30 表示 30 秒) + * @param unit 时间单位(如秒、分钟等) + */ public void renew(long delay, TimeUnit unit) { this.expireAt = System.currentTimeMillis() + unit.toMillis(delay); }