diff --git a/car_srv/kotlinSrv/src/McTransport.kt b/car_srv/kotlinSrv/src/McTransport.kt index 63d49a3dc90..63570426ed6 100644 --- a/car_srv/kotlinSrv/src/McTransport.kt +++ b/car_srv/kotlinSrv/src/McTransport.kt @@ -10,9 +10,10 @@ class McTransport() { private var callback: (bytes: ByteArray) -> Unit = {} fun writeToFile(bytes: ByteArray) { + println("writewrite uiii!") val bytesT = bytes writeStream.write(js("new Buffer(bytesT)")); - writeStream.end(); +// writeStream.end(); } fun writeToFile(byte: Byte) { @@ -45,6 +46,7 @@ class McTransport() { } fun closeStreams() { + writeStream.end() writeStream = null readStream = null } diff --git a/car_srv/kotlinSrv/src/MicroController.kt b/car_srv/kotlinSrv/src/MicroController.kt index 8f36d24d565..d587d984d14 100644 --- a/car_srv/kotlinSrv/src/MicroController.kt +++ b/car_srv/kotlinSrv/src/MicroController.kt @@ -37,6 +37,9 @@ class MicroController private constructor() { this.transportFilePath = "./testTtyAcm"//todo need init mcTransport.initStreams(transportFilePath) + mcTransport.setCallBack { bytes -> + println("read: " + bytes.toString()) + } setInterval({ this.car.refreshLocation(deltaTimeLocationRefresh) }, deltaTimeLocationRefresh); setInterval({