fixed test
This commit is contained in:
parent
9478acc0f4
commit
eceb9bbcee
@ -59,7 +59,7 @@ class MultipleServerTest : BaseTest() {
|
|||||||
var serverAeronDir: File? = null
|
var serverAeronDir: File? = null
|
||||||
val didReceive = mutableListOf<AtomicBoolean>()
|
val didReceive = mutableListOf<AtomicBoolean>()
|
||||||
|
|
||||||
for (count in 0..total) {
|
for (count in 0 until total) {
|
||||||
didReceive.add(AtomicBoolean())
|
didReceive.add(AtomicBoolean())
|
||||||
val offset = count * portOffset
|
val offset = count * portOffset
|
||||||
|
|
||||||
@ -71,7 +71,7 @@ class MultipleServerTest : BaseTest() {
|
|||||||
val server: Server<Connection> = Server(configuration)
|
val server: Server<Connection> = Server(configuration)
|
||||||
addEndPoint(server)
|
addEndPoint(server)
|
||||||
|
|
||||||
server.onMessage<String>{ connection, message ->
|
server.onMessage<String>{ _, message ->
|
||||||
if (message != "client_$count") {
|
if (message != "client_$count") {
|
||||||
Assert.fail()
|
Assert.fail()
|
||||||
}
|
}
|
||||||
@ -93,7 +93,7 @@ class MultipleServerTest : BaseTest() {
|
|||||||
var clientAeronDir: File? = null
|
var clientAeronDir: File? = null
|
||||||
val didSend = mutableListOf<AtomicBoolean>()
|
val didSend = mutableListOf<AtomicBoolean>()
|
||||||
|
|
||||||
for (count in 0..total) {
|
for (count in 0 until total) {
|
||||||
didSend.add(AtomicBoolean())
|
didSend.add(AtomicBoolean())
|
||||||
val offset = count * portOffset
|
val offset = count * portOffset
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user