fixed warnings
This commit is contained in:
parent
b3f1ecf368
commit
8550a24c04
|
@ -183,7 +183,7 @@ class PingPongTest : BaseTest() {
|
|||
return false
|
||||
}
|
||||
|
||||
val other = other as Data
|
||||
other as Data
|
||||
if (!Booleans.contentEquals(other.Booleans)) {
|
||||
return false
|
||||
}
|
||||
|
|
|
@ -33,7 +33,7 @@ class SerializationValidationTest : BaseTest() {
|
|||
val server = Server<Connection>(configuration)
|
||||
addEndPoint(server)
|
||||
|
||||
server.onMessage<FinishedCommand> { message ->
|
||||
server.onMessage<FinishedCommand> { _ ->
|
||||
stopEndPoints()
|
||||
}
|
||||
server.bind()
|
||||
|
@ -83,7 +83,7 @@ class SerializationValidationTest : BaseTest() {
|
|||
|
||||
server.rmiGlobal.save(TestObjectImpl(), 1)
|
||||
|
||||
server.onMessage<TestObject> { message ->
|
||||
server.onMessage<TestObject> { _ ->
|
||||
stopEndPoints()
|
||||
}
|
||||
server.bind()
|
||||
|
@ -129,7 +129,7 @@ class SerializationValidationTest : BaseTest() {
|
|||
|
||||
server.rmiGlobal.save(TestObjectImpl(), 1)
|
||||
|
||||
server.onMessage<TestObject> { message ->
|
||||
server.onMessage<TestObject> { _ ->
|
||||
stopEndPoints()
|
||||
}
|
||||
server.bind()
|
||||
|
@ -573,6 +573,7 @@ class SerializationValidationTest : BaseTest() {
|
|||
fun other(): Float
|
||||
}
|
||||
|
||||
@Suppress("UNUSED_PARAMETER")
|
||||
private class TestObjectImpl : TestObject {
|
||||
private var aFloat = 0f
|
||||
override suspend fun setValue(aFloat: Float) {
|
||||
|
|
|
@ -161,6 +161,7 @@ abstract class KryoTestCase {
|
|||
|
||||
/** @param length Pass Integer.MIN_VALUE to disable checking the length.
|
||||
*/
|
||||
@Suppress("UNCHECKED_CAST")
|
||||
fun <T> roundTripWithBufferFactory(length: Int, object1: T, sf: BufferFactory): T {
|
||||
val checkLength = length != Int.MIN_VALUE
|
||||
this.object1 = object1
|
||||
|
@ -174,7 +175,7 @@ abstract class KryoTestCase {
|
|||
|
||||
// Test input from stream, large buffer.
|
||||
val out = outStream.toByteArray()
|
||||
input = sf.createInput(ByteArrayInputStream(outStream.toByteArray()), 4096)
|
||||
input = sf.createInput(ByteArrayInputStream(out), 4096)
|
||||
object2 = kryo!!.readClassAndObject(input)
|
||||
doAssertEquals(object1, object2)
|
||||
if (checkLength) {
|
||||
|
|
|
@ -222,13 +222,13 @@ class MemoryTest : BaseTest() {
|
|||
|
||||
private class TestObjectImpl(private val counter: AtomicLong) : TestObject {
|
||||
@Override
|
||||
override fun setOther(aFloat: Long): Boolean {
|
||||
override fun setOther(value: Long): Boolean {
|
||||
counter.getAndIncrement()
|
||||
return true
|
||||
}
|
||||
|
||||
@Override
|
||||
override suspend fun setOtherSus(aFloat: Long): Boolean {
|
||||
override suspend fun setOtherSus(value: Long): Boolean {
|
||||
counter.getAndIncrement()
|
||||
return true
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue