diff options
| -rw-r--r-- | src/main/kotlin/TransportLayer.kt | 2 | ||||
| -rw-r--r-- | src/main/kotlin/TransportLayerJavaNet.kt | 5 |
2 files changed, 4 insertions, 3 deletions
diff --git a/src/main/kotlin/TransportLayer.kt b/src/main/kotlin/TransportLayer.kt index bdfc04e..8b31d20 100644 --- a/src/main/kotlin/TransportLayer.kt +++ b/src/main/kotlin/TransportLayer.kt @@ -24,7 +24,7 @@ interface TransportLayer : Closeable { * * @throws java.io.IOException if the message could not be correctly transmitted. */ - fun transmit(payload: Array<UByte>) + fun transmit(payload: Iterable<UByte>) /* /** * Receive a payload until a byte occurs, which marks the end of the message. The byte is discarded after being read diff --git a/src/main/kotlin/TransportLayerJavaNet.kt b/src/main/kotlin/TransportLayerJavaNet.kt index e48ac16..ee1c9f9 100644 --- a/src/main/kotlin/TransportLayerJavaNet.kt +++ b/src/main/kotlin/TransportLayerJavaNet.kt @@ -46,8 +46,9 @@ class TransportLayerJavaNet(val address: String, val port: UShort) : TransportLa this.socket.close() } - override fun transmit(payload: Array<UByte>) { - val bytes = ByteArray(payload.size) { i -> payload[i].toByte() } + override fun transmit(payload: Iterable<UByte>) { + val payload = payload.toList() + val bytes = ByteArray(payload.size, { i -> payload[i].toByte() }) this.outStream.write(bytes) } |