Merge pull request #1204 from akka/wip-3093-removing-temporal-constraints-√
#3093 - removing the temporal constraints on TcpConnectionSpec
This commit is contained in:
commit
b92d0a42ca
1 changed files with 2 additions and 2 deletions
|
|
@ -504,8 +504,8 @@ class TcpConnectionSpec extends AkkaSpec("akka.io.tcp.register-timeout = 500ms")
|
||||||
watch(connectionActor)
|
watch(connectionActor)
|
||||||
EventFilter[DeathPactException](occurrences = 1) intercept {
|
EventFilter[DeathPactException](occurrences = 1) intercept {
|
||||||
system.stop(connectionHandler.ref)
|
system.stop(connectionHandler.ref)
|
||||||
expectMsgType[Terminated].actor must be(connectionHandler.ref)
|
val deaths = Set(expectMsgType[Terminated].actor, expectMsgType[Terminated].actor)
|
||||||
expectMsgType[Terminated].actor must be(connectionActor)
|
deaths must be(Set(connectionHandler.ref, connectionActor))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue