Function cleanupPendingSubblocksForSocket

apps/realtime/src/handlers/subblocks.ts:32–43

(socketId: string)

 * Removes the socket's operationIds from pending updates to prevent memory leaks.
 */
export function cleanupPendingSubblocksForSocket(socketId: string): void {
  for (const [, pending] of pendingSubblockUpdates.entries()) {
    // Remove this socket's operation entries
    for (const [opId, sid] of pending.opToSocket.entries()) {
      if (sid === socketId) {
        pending.opToSocket.delete(opId)
      }
    }
    // If no more operations are waiting, the timeout will still fire and flush
    // This is fine - the update will still persist, just no confirmation to send
  }
}

export function setupSubblocksHandlers(socket: AuthenticatedSocket, roomManager: IRoomManager) {
  socket.on('subblock-update', async (data) => {