diff options
Diffstat (limited to 'src/main')
-rw-r--r-- | src/main/kotlin/NetworkPacketTransporter.kt | 8 | ||||
-rw-r--r-- | src/main/kotlin/NetworkPacketTransporterJavaNet.kt | 6 |
2 files changed, 8 insertions, 6 deletions
diff --git a/src/main/kotlin/NetworkPacketTransporter.kt b/src/main/kotlin/NetworkPacketTransporter.kt index e12a6ac..eef0aea 100644 --- a/src/main/kotlin/NetworkPacketTransporter.kt +++ b/src/main/kotlin/NetworkPacketTransporter.kt @@ -48,8 +48,8 @@ abstract class NetworkPacketTransporter : Closeable { * * @throws java.io.IOException if the message could not be correctly transmitted. */ - abstract fun transmit(payload: Array<UByte>) +/* /** * Receive a payload until a byte occurs, which marks the end of the message. The byte is discarded after being read * and is not returned. @@ -58,11 +58,11 @@ abstract class NetworkPacketTransporter : Closeable { * [receiveFixed] instead, which is usually more efficient. * * @param untilByte The byte that marks the end of the message. - * + * @return the received payload. * @throws java.io.IOException if the message could not be correctly received. */ - abstract fun receiveUntil(untilByte: Byte): List<Byte> - + abstract fun receiveUntil(untilByte: UByte): Array<UByte> +*/ /** * Receive a payload with fixed length. If zero, nothing is read. * diff --git a/src/main/kotlin/NetworkPacketTransporterJavaNet.kt b/src/main/kotlin/NetworkPacketTransporterJavaNet.kt index 6855604..fe2c87c 100644 --- a/src/main/kotlin/NetworkPacketTransporterJavaNet.kt +++ b/src/main/kotlin/NetworkPacketTransporterJavaNet.kt @@ -42,9 +42,10 @@ class NetworkPacketTransporterJavaNet : NetworkPacketTransporter { this.outStream.write(bytes) } - override fun receiveUntil(untilByte: Byte): List<Byte> { +/* + override fun receiveUntil(untilByte: UByte): Array<UByte> { var stop = false - val payload: MutableList<Byte> = MutableList(0, { 0 }) + val payload: Array<UByte> = MutableList(0, { 0 }) while (!stop) { val b = this.inStream.readNBytes(1)[0] if (b == untilByte) { @@ -56,6 +57,7 @@ class NetworkPacketTransporterJavaNet : NetworkPacketTransporter { } return payload } +*/ override fun receive(length: ULong): Array<UByte> { var length = length |