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

Merge pull request #18184 from KadekM/todo-si6208-fix-kadekm

Browse source 
tiny update to code as SI-6208 is resolved
This commit is contained in:
Konrad Malawski 2015-08-12 23:22:13 +02:00
commit 986c5e8934
1 changed files with 1 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-actor/src/main/scala/akka/actor/dsl/Inbox.scala
View file

@ -116,8 +116,7 @@ trait Inbox { this: ActorDSL.type ⇒
val toKick = overdue.next()
toKick.client ! Status.Failure(new TimeoutException("deadline passed"))
}
// TODO: this wants to lose the `Queue.empty ++=` part when SI-6208 is fixed
clients = Queue.empty ++= clients.filterNot(pred)
clients = clients.filterNot(pred)
clientsByTimeout = clientsByTimeout.from(Get(now))
case msg ⇒
if (clients.isEmpty) enqueueMessage(msg)