Write header before starting scribe

sbt · Oct 15, 2024 · 048b779 · 048b779
1 parent 9089fcd
commit 048b779
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 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/internal/zinc-persist/src/test/scala/sbt/inc/consistent/ConsistentAnalysisFormatSuite.scala b/internal/zinc-persist/src/test/scala/sbt/inc/consistent/ConsistentAnalysisFormatSuite.scala
@@ -2,7 +2,6 @@ package sbt.inc.consistent
 
 import org.scalatest.funsuite.AnyFunSuite
 import sbt.internal.inc.consistent.*
-import sbt.internal.inc.consistent.Compat.*
 import sbt.io.IO
 
 import java.io.*

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],