diff --git a/akka-stream/src/main/scala/akka/stream/impl/QueueSource.scala b/akka-stream/src/main/scala/akka/stream/impl/QueueSource.scala
index 1332f72acd..95cd63658f 100644
--- a/akka-stream/src/main/scala/akka/stream/impl/QueueSource.scala
+++ b/akka-stream/src/main/scala/akka/stream/impl/QueueSource.scala
@@ -95,7 +95,7 @@ import scala.concurrent.{ Future, Promise }
                 case Some(_) =>
                   offer.promise.failure(
                     new IllegalStateException(
-                      "You have to wait for previous offer to be resolved to send another request"))
+                      "You have to wait for the previous offer to be resolved to send another request"))
                 case None =>
                   pendingOffer = Some(offer)
               }