diff --git a/src/input/ThreadInputStream.cxx b/src/input/ThreadInputStream.cxx
index dbe3be20b..dc8fa10a0 100644
--- a/src/input/ThreadInputStream.cxx
+++ b/src/input/ThreadInputStream.cxx
@@ -111,7 +111,7 @@ ThreadInputStream::IsAvailable() const noexcept
 {
 	assert(!thread.IsInside());
 
-	return !buffer.empty() || eof || postponed_exception;
+	return !IsEOF() || postponed_exception;
 }
 
 inline size_t