diff --git a/src/input/ThreadInputStream.cxx b/src/input/ThreadInputStream.cxx
index dc8fa10a0..46dfea465 100644
--- a/src/input/ThreadInputStream.cxx
+++ b/src/input/ThreadInputStream.cxx
@@ -131,7 +131,7 @@ ThreadInputStream::Read(std::unique_lock<Mutex> &lock,
 			size_t nbytes = std::min(dest.size(), r.size());
 			memcpy(dest.data(), r.data(), nbytes);
 			buffer.Consume(nbytes);
-			wake_cond.notify_all();
+			wake_cond.notify_one();
 			offset += nbytes;
 			return nbytes;
 		}