Write header before starting scribe

sbt · Oct 15, 2024 · f8c0a91 · f8c0a91
1 parent f043798
commit f8c0a91
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...al/zinc-persist/src/main/scala/sbt/internal/inc/consistent/ParallelGzipOutputStream.scala b/...al/zinc-persist/src/main/scala/sbt/internal/inc/consistent/ParallelGzipOutputStream.scala
@@ -99,7 +99,6 @@ object ParallelGzipOutputStream {
     }
 
     override def run(): Unit = {
-      out.write(header)
       loop()
     }
   }
@@ -128,6 +127,8 @@ final class ParallelGzipOutputStream(out: OutputStream, parallelism: Int)
   private val workerCount = math.max(1, parallelism - 1)
   private val workers = new ArrayBlockingQueue[Worker](workerCount)
   private val buffers = new LinkedTransferQueue[Block]()
+
+  out.write(header)
   private val scribe = new Scribe(out, buffers)
   scribe.start()