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

No, seriously, fixing ticket #703

Browse source
This commit is contained in:
Viktor Klang 2011-03-15 00:53:40 +01:00
parent 38b291749a
commit 63bad2bb12
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor/src/main/scala/akka/routing/Pool.scala
View file

@ -73,7 +73,7 @@ trait DefaultActorPool extends ActorPool { this: Actor =>
case None =>
delegate ! msg
case Some(future) =>
future completeWith (delegate.!!!(msg, TimeUnit.NANOSECONDS.toMillis(future.timeoutInNanos)))
delegate.!!!(msg, TimeUnit.NANOSECONDS.toMillis(future.timeoutInNanos)).onComplete( future.completeWith(_) )
}
}
}