diff --git a/internal/camera/discovery/scanner.go b/internal/camera/discovery/scanner.go
index 6296333..e8ff25d 100644
--- a/internal/camera/discovery/scanner.go
+++ b/internal/camera/discovery/scanner.go
@@ -409,26 +409,20 @@ func (s *Scanner) testStreamsConcurrently(ctx context.Context, streams []models.
 	defer cancelProgress()
 
 	go func() {
-		ticker := time.NewTicker(3 * time.Second)
+		ticker := time.NewTicker(1 * time.Second)
 		defer ticker.Stop()
 
-		lastTested := int32(0)
-
 		for {
 			select {
 			case <-progressCtx.Done():
 				return
 			case <-ticker.C:
-				currentTested := atomic.LoadInt32(&tested)
-				// Only send if there's been progress
-				if currentTested != lastTested {
-					_ = streamWriter.SendJSON("progress", models.ProgressMessage{
-						Tested:    int(currentTested),
-						Found:     int(atomic.LoadInt32(&found)),
-						Remaining: len(streams) - int(currentTested),
-					})
-					lastTested = currentTested
-				}
+				// Send progress every second to prevent WriteTimeout
+				_ = streamWriter.SendJSON("progress", models.ProgressMessage{
+					Tested:    int(atomic.LoadInt32(&tested)),
+					Found:     int(atomic.LoadInt32(&found)),
+					Remaining: len(streams) - int(atomic.LoadInt32(&tested)),
+				})
 			}
 		}
 	}()
diff --git a/internal/config/config.go b/internal/config/config.go
index 961aebe..719bd30 100644
--- a/internal/config/config.go
+++ b/internal/config/config.go
@@ -73,7 +73,7 @@ func Load() *Config {
 		Server: ServerConfig{
 			Listen:       ":4567", // Default listen address
 			ReadTimeout:  30 * time.Second,
-			WriteTimeout: 30 * time.Second,
+			WriteTimeout: 5 * time.Minute, // Increased for SSE long-polling
 		},
 		Database: DatabaseConfig{
 			DataPath:       dataPath,