JavaScriptIOT
diff --git a/‎src/rawchannel.cc‎
Lines changed: 1 addition & 4 deletions b/‎src/rawchannel.cc‎
Lines changed: 1 addition & 4 deletions
diff --git a/‎tests/test-raw_basic.js‎
Lines changed: 18 additions & 0 deletions b/‎tests/test-raw_basic.js‎
Lines changed: 18 additions & 0 deletions
@@ -286,11 +286,8 @@ class RawChannel : public Nan::ObjectWrap
 
     CHECK_CONDITION(hw->m_Thread, "Channel not started");
 
-    hw->stopThread();
+    hw->async_channel_stopped();
 
-    uv_close((uv_handle_t *)&hw->m_AsyncReceiverReady, NULL);
-    uv_close((uv_handle_t *)&hw->m_AsyncChannelStopped, NULL);
-    hw->Unref();
     info.GetReturnValue().Set(info.This());
   }
 
 
@@ -34,6 +34,24 @@ exports['channel_error'] = function(test) {
 	channel.start();
 }
 
+exports['channel_stopped'] = function(test) {
+	var channel = can.createRawChannel("vcan0");
+	var stop_called = false;
+
+	channel.addListener("onStopped", function() {
+		stop_called = true
+	});
+	
+	channel.start();
+	
+	setTimeout(function() { channel.stop(); }, 100);
+
+	setTimeout(function() {
+		test.ok(stop_called)
+		test.done()
+	}, 100);
+}
+
 // Send 100 messages from c2 to c1
 exports['rxtx_test'] = function(test) {
 	var c1 = can.createRawChannelWithOptions("vcan0", { timestamps: true });
Original file line number	Diff line number	Diff line change
`@@ -286,11 +286,8 @@ class RawChannel : public Nan::ObjectWrap`
`286`	`286`
`287`	`287`	`CHECK_CONDITION(hw->m_Thread, "Channel not started");`
`288`	`288`
`289`		`- hw->stopThread();`
	`289`	`+ hw->async_channel_stopped();`
`290`	`290`
`291`		`- uv_close((uv_handle_t *)&hw->m_AsyncReceiverReady, NULL);`
`292`		`- uv_close((uv_handle_t *)&hw->m_AsyncChannelStopped, NULL);`
`293`		`- hw->Unref();`
`294`	`291`	`info.GetReturnValue().Set(info.This());`
`295`	`292`	`}`
`296`	`293`