File tree Expand file tree Collapse file tree 1 file changed +15
-1
lines changed Expand file tree Collapse file tree 1 file changed +15
-1
lines changed Original file line number Diff line number Diff line change @@ -1317,7 +1317,7 @@ class Client {
13171317 if (_sendQueue .length > 0 ) {
13181318 _sendLock .execute (() -> {
13191319 trace (' Sending ${_sendQueue .length } queued packet(s)' );
1320- _ws .send (TJson .stringify (_sendQueue ));
1320+ _ws .send (haxe.io. Bytes . ofString ( TJson .stringify (_sendQueue ) ));
13211321 _sendQueue = [];
13221322 });
13231323 }
@@ -1702,6 +1702,20 @@ class Client {
17021702 }
17031703 });
17041704
1705+ case BytesMessage (bytes ):
1706+ _recvLock .execute (() -> {
1707+ try {
1708+ var content = bytes .readAllAvailableBytes ().toString ();
1709+ var newPackets : Array <IncomingPacket > = TJson .parse (content );
1710+ // trace(newPackets);
1711+ for (newPacket in newPackets )
1712+ _recvQueue .push (newPacket );
1713+ } catch (e ) {
1714+ trace (" EXCEPTION onmessage: " + e );
1715+ _hOnThrow (" onmessage" , e );
1716+ }
1717+ });
1718+
17051719 default :
17061720 }
17071721 }
You can’t perform that action at this time.
0 commit comments