X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=test%2FAFB.js;h=44b1a9084a89b57c2282f0134242d3c7accaa0b1;hb=9e3afb8aa598f3e69e2c3723335507c12b4cd1f1;hp=309db472c2bb894c270c6a843d7165667082ca8c;hpb=46d9538587a3521caa1e3b20bf337a53ed400777;p=src%2Fapp-framework-binder.git

diff --git a/test/AFB.js b/test/AFB.js
index 309db472..44b1a908 100644
--- a/test/AFB.js
+++ b/test/AFB.js
@@ -37,12 +37,14 @@ var AFB_websocket;
 	var CALL = 2;
 	var RETOK = 3;
 	var RETERR = 4;
+	var EVENT = 5;
 
 	var PROTO1 = "x-afb-ws-json1";
 
 	AFB_websocket = function(onopen, onabort) {
 		this.ws = new WebSocket(urlws, [ PROTO1 ]);
 		this.pendings = {};
+		this.awaitens = {};
 		this.counter = 0;
 		this.ws.onopen = onopen.bind(this);
 		this.ws.onerror = onerror.bind(this);
@@ -90,6 +92,10 @@ var AFB_websocket;
 			delete this.pendings[id];
 		}
 		switch (code) {
+		case EVENT:
+			var a = this.awaitens[id];
+			if (a)
+				a.forEach(function(handler){handler(ans);});
 		case RETOK:
 			pend && pend.onsuccess && pend.onsuccess(ans, this);
 			break; 
@@ -112,9 +118,16 @@ var AFB_websocket;
 		this.ws.send(JSON.stringify(arr));
 	}
 
+	function onevent(api, name, handler) {
+		var id = api+"/"+name;
+		var list = this.awaitens[id] || (this.awaitens[id] = []);
+		list.push(handler);
+	}
+
 	AFB_websocket.prototype = {
 		close: close,
-		call: call
+		call: call,
+		onevent: onevent
 	};
 }
 /*********************************************/