From 65baf23daa96b9bfcd3c4047bf917c0266ce360d Mon Sep 17 00:00:00 2001
From: MaximZaitsev <AnterKan1@gmail.com>
Date: Tue, 16 Aug 2016 17:06:06 +0300
Subject: [PATCH] add default callback on read (just print bytes). fixed
 closing write stream after first write

---
 car_srv/kotlinSrv/src/McTransport.kt     | 4 +++-
 car_srv/kotlinSrv/src/MicroController.kt | 3 +++
 2 files changed, 6 insertions(+), 1 deletion(-)

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({