#3093 - removing the temporal constraints on TcpConnectionSpec
This commit is contained in:
parent
eb057743d7
commit
aa16bfaa66
1 changed files with 2 additions and 2 deletions
|
|
@ -501,8 +501,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