diff --git a/stream.c b/stream.c
index 0dc68be..357f921 100644
--- a/stream.c
+++ b/stream.c
@@ -1567,14 +1567,12 @@ static int fill_buffer(rzip_control *control, struct stream_info *sinfo, struct
 	i64 u_len, c_len, last_head, padded_len, header_length, max_len;
 	uchar enc_head[25 + SALT_LEN], blocksalt[SALT_LEN];
 	stream_thread_struct *st;
-	bool new_thread = false;
 	uchar c_type, *s_buf;
 
 	dealloc(s->buf);
 	if (s->eos)
 		goto out;
 fill_another:
-	new_thread = true;
 	if (unlikely(ucthread[s->uthread_no].busy))
 		failure_return(("Trying to start a busy thread, this shouldn't happen!\n"), -1);
 
@@ -1704,7 +1702,7 @@ out:
 	unlock_mutex(control, &output_lock);
 
 	/* join_pthread here will make it wait till the data is ready */
-	if (unlikely(new_thread && !join_pthread(control, threads[s->unext_thread], NULL)))
+	if (unlikely(!join_pthread(control, threads[s->unext_thread], NULL)))
 		return -1;
 	ucthread[s->unext_thread].busy = 0;