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

Merge pull request #21367 from akka/wip-21331-SystemMessageDeliverySpec-patriknw

Browse source 
fix failing SystemMessageDeliverySpec, #21331
This commit is contained in:
Patrik Nordwall 2016-09-07 10:44:59 +02:00 • committed by GitHub
commit b8b57df5e9
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-remote/src/test/scala/akka/remote/artery/TestContext.scala
View file

@ -126,12 +126,12 @@ private[remote] class ManualReplyInboundContext(
private var lastReply: Option[(Address, ControlMessage)] = None
override def sendControl(to: Address, message: ControlMessage) = {
override def sendControl(to: Address, message: ControlMessage): Unit = synchronized {
lastReply = Some((to, message))
replyProbe ! message
}
def deliverLastReply(): Unit = {
def deliverLastReply(): Unit = synchronized {
lastReply.foreach { case (to, message) ⇒ super.sendControl(to, message) }
lastReply = None
}