From f8c0a91527e0b79b06d2740d3899a22c0a66aa10 Mon Sep 17 00:00:00 2001 From: friendseeker <66892505+Friendseeker@users.noreply.github.com> Date: Mon, 14 Oct 2024 17:17:30 -0700 Subject: [PATCH] Write header before starting scribe --- .../sbt/internal/inc/consistent/ParallelGzipOutputStream.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/zinc-persist/src/main/scala/sbt/internal/inc/consistent/ParallelGzipOutputStream.scala b/internal/zinc-persist/src/main/scala/sbt/internal/inc/consistent/ParallelGzipOutputStream.scala index f66aff12b..b5de1c1bf 100644 --- a/internal/zinc-persist/src/main/scala/sbt/internal/inc/consistent/ParallelGzipOutputStream.scala +++ b/internal/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()