From 0646d2d36a024b868a770068e094bcfd0e71b856 Mon Sep 17 00:00:00 2001
From: kerr <hepin1989@gmail.com>
Date: Thu, 14 Mar 2019 18:20:31 +0800
Subject: [PATCH] Fix typo in QueueSource's error message. (#26509)

---
 akka-stream/src/main/scala/akka/stream/impl/QueueSource.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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)
               }