Open socket when re-sending pending messages

2025-08-22 12:37:19 -07:00
parent eca1ce849b
commit 24ed236a46
1 changed files with 2 additions and 0 deletions
@@ -138,6 +138,8 @@ export const socketPolicyCloseInactive = (socket: Socket) => {
      // If the socket closed and we have no error, reopen it but don't flap
      if (isClosed && pending.size) {
        sleep(Math.max(0, ms(5 - (now() - lastOpen)))).then(() => {
          socket.attemptToOpen()
          for (const message of pending.values()) {
            socket.send(message)
          }