From dbcf894ed726825ffe36fd5cd7c977a8db983320 Mon Sep 17 00:00:00 2001
From: simlu <simlu@users.noreply.github.com>
Date: Wed, 11 Oct 2017 18:51:40 -0700
Subject: [PATCH] add() would crash, while put() blocks

Discussion can be found here: https://github.com/shevek/parallelgzip/issues/8
---
 .../java/org/anarres/parallelgzip/ParallelGZIPOutputStream.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/org/anarres/parallelgzip/ParallelGZIPOutputStream.java b/src/main/java/org/anarres/parallelgzip/ParallelGZIPOutputStream.java
index c0abf30..894d591 100644
--- a/src/main/java/org/anarres/parallelgzip/ParallelGZIPOutputStream.java
+++ b/src/main/java/org/anarres/parallelgzip/ParallelGZIPOutputStream.java
@@ -230,7 +230,7 @@ public void write(byte[] b, int off, int len) throws IOException {
     // Master thread only
     private void submit() throws IOException {
         emitUntil(emitQueueSize - 1);
-        emitQueue.add(executor.submit(block));
+        emitQueue.put(executor.submit(block));
         Block b = freeBlock;
         if (b != null)
             freeBlock = null;