@@ -3,6 +3,7 @@ class JsSocket { static var id:String; static var buffer:String = ""; static var sizedReads:Bool = false; + static var packetSize:Int = -1; static var slash:EReg = ~/\\/g; private static function calljs(type, data:Dynamic) { @@ -46,8 +47,26 @@ class JsSocket { socket.addEventListener(flash.events.ProgressEvent.SOCKET_DATA, function(d){ if (sizedReads) { - while (socket.bytesAvailable > 0) - calljs('onData', slash.replace(socket.readUTF(), '\\\\')); + while (socket.bytesAvailable > 0) { + // figure out the packet size + if (packetSize > -1) { + // we have it already + } else if (socket.bytesAvailable >= 2) { + // read the packet size + packetSize = socket.readShort(); + } else { + // lets wait + break; + } + + // read the packet, if possible + if (socket.bytesAvailable >= packetSize) { + calljs('onData', slash.replace(socket.readUTFBytes(packetSize), '\\\\')); + packetSize = -1; + } else { + break; + } + } } else { var size = socket.bytesAvailable; var data = new flash.utils.ByteArray(); flash/JsSocket.hx flash/jsSocket2.swf 72e1a45c3405978579e66cfc1d4bbf6589e794df Aman Gupta aman@tmm1.net http://github.com/tmm1/jssocket/commit/c0e8a8794f916cf0a08ccd09061ab2244a580945 c0e8a8794f916cf0a08ccd09061ab2244a580945 2009-01-21T18:39:37-08:00 2009-01-21T18:39:37-08:00 fixed sizedMode in jsSocket2 (socket.readUTF() throws EOFError when complete string is not available) 51b527fa8158ea49ef0f699cc68fabf8e90d41c6 Aman Gupta aman@tmm1.net