Write header before starting scribe

sbt · Oct 15, 2024 · 9c7766a · 9c7766a
1 parent f043798
commit 9c7766a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
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()
 

diff --git a/...inc-persist/src/test/scala/sbt/inc/consistent/ParallelGzipOutputStreamSpecification.scala b/...inc-persist/src/test/scala/sbt/inc/consistent/ParallelGzipOutputStreamSpecification.scala
@@ -67,7 +67,7 @@ class ParallelGzipOutputStreamSpecification extends AnyFlatSpec with Matchers {
   def sanitizedFilename(fileName: String): String = {
     fileName.replaceAll("[^a-zA-Z0-9-_.]", "_")
   }
-  
+
   def handleFailure(
       compressed: Array[Byte],
       data: Array[Byte],