diff --git a/rivetkit-typescript/packages/rivetkit/src/actor/instance/connection-manager.ts b/rivetkit-typescript/packages/rivetkit/src/actor/instance/connection-manager.ts index e12106ce80..cfbd830942 100644 --- a/rivetkit-typescript/packages/rivetkit/src/actor/instance/connection-manager.ts +++ b/rivetkit-typescript/packages/rivetkit/src/actor/instance/connection-manager.ts @@ -335,6 +335,7 @@ export class ConnectionManager< this.#actor.inspector.emitter.emit("connectionsUpdated"); this.#pendingDisconnectCount += 1; + this.#actor.resetSleepTimer(); const attributes = { "rivet.conn.id": conn.id, diff --git a/rivetkit-typescript/packages/rivetkit/src/actor/instance/mod.ts b/rivetkit-typescript/packages/rivetkit/src/actor/instance/mod.ts index 994eac3b1a..c77607136c 100644 --- a/rivetkit-typescript/packages/rivetkit/src/actor/instance/mod.ts +++ b/rivetkit-typescript/packages/rivetkit/src/actor/instance/mod.ts @@ -2436,6 +2436,10 @@ export class ActorInstance< if (timeoutMs !== undefined) { this.#sleepTimeout = setTimeout(() => { + if (this.#canSleep() !== CanSleep.Yes) { + this.resetSleepTimer(); + return; + } this.startSleep(); }, timeoutMs); }