raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Fix typo in QueueSource's error message. (#26509)

Browse source
This commit is contained in:
kerr 2019-03-14 18:20:31 +08:00 • committed by Arnout Engelen
parent 48a43e1e74
commit 0646d2d36a
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/scala/akka/stream/impl/QueueSource.scala
View file

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