More modules!

Local count:=ReadInt()
For Local i:=0 Until count
  Local strLen:=ReadInt()
  ...read string etc...

Interface ImageListener
    Method ImageLoaded:Void( image:Image,success:Bool )
End

Function Main()
	Local stream:=New TCPStream
	
	If stream.Connect( "www.blitzbasic.com",80 )
		Print "Connected!"
		stream.WriteLine "GET / HTTP/1.0"
		stream.WriteLine "Host: www.blitzbasic.com"
		stream.WriteLine ""
		Local n:=0
		While Not stream.Eof()
			Local line:=stream.ReadLine()
			Print line
		Wend
		stream.Close
		Print "BYE!!!!"
	Else
		Print "Failed to connect!"
	Endif
End

Class MyStreamManager implements StreamListener
	Method OnDataAvailable:Buffer(data:Buffer)
		'check for end of line
		if data contains eol
			line = slice up Until EOL
			
			data = slice after EOL
			
			Return data
		Else
			Return data
		EndIf
	End
End

Interface IOnReadPageComplete
	Method OnReadPageComplete:Void( page:String )
End

Class WebBrowser Implements OnReadLineComplete

	'Can block, so we use a completion hander...
	Method ReadPage:Void( url:String,onComplete:IOnReadPageComplete )
		...
	End

	...eventually executes initial ReadLine to kickstart things...

	'Our new while loop!
	Method OnReadLineComplete:Void( line:String )
		If line 'empty line=Eof.
			'Received another line
			_buf.Push line	   		'push line on a StringStack
			_stream.ReadLine Self   'start reading next line.
		Else
			'Eof!
			Local page:=_buf.Join("")
			_onComplete.OnGetPageComplete( page )
		Endif
	End

	...
	
End

Interface IOnReadComplete
	Method OnReadComplete:Void( buf:DataBuffer,offset:Int,count:Int )
End

Class Stream	'Extended by native TCPStream...
	Method Read:Void( buf:DataBuffer,offset:Int,count:Int,onComplete:IOnReadComplete ) Abstract
End

Class Actor
   Method Read:Void( stream:Stream )
      stream.Read x,y,state etc
   End

   Method Write:Void( stream:Stream )
      stream.Write x,y,state etc
   End
End

Interface IOnReadAllComplete
   Method OnReadAllComplete:Void( buffer:DataBuffer,offset:Int,count:Int... )
End

Interface IOnReadBlockComplete
   Method OnReadBlockComplete:Void( buffer:DataBuffer,offset:Int,count:Int... )
End

'new methods in AsyncStream

   'read until EOF
   Method ReadAll:Void( buffer:DataBuffer,offset:Int,onComplete:IOnRealAllComplete ) 

   'read length/databuffer
   Method ReadBlock:Void( buffer:DataBuffer,offset:Int,onComplete:IOnReadBlockComplete )

Method OnReadChunkComplete:Void( data:DataBuffer,offset,length )
   'OK, data contains an entire message from the server!
   ProcessServerMessage data,length
   'Start receiving next message
   stream.ReadChunk data,0   'OK, next message please!
End

Method ProcessServerMessage( data:DataBuffer,length )
   If data.PeekInt(0)=GAMESTATE_UPDATE
      ...apply gamestate changes...
   ElseIf data.PeekInt(0)=PLAYER_CHAT
      ...etc...
   Endif
End

Repeat
  Local data:=ReadServerMessage()
  ProcessServerMessage data
Forever

{
     z: 1,
     id: 1234590,
     s: {
       x: 5,
       y: 34,
       v: 3,
       a: 0.46
     } 
}

Function SendJSONObject:Void( obj:JSONObject,stream:AsyncStream )
   Local data:=New DataBuffer( MAX_JSON_SIZE )
   Local dstream:=New DataStream( data )
   WriteObjectToStream( obj,dstream )
   Local length:=dstream.Position
   'possibly compress databuffer here...
   stream.WriteChunk data,length
End

Method OnReadChunkComplete:Void( data:DataBuffer,offset:int,length:int,stream:AsyncStream )
   'possibly decompress databuffer here...
   Local dstream:=new DataStream( data,0,length )
   Local obj:=ReadObjectFromStream( dstream )
   stream.ReadChunk data,data.Length   'kick off the next read...
   '
   'OK, an object has arrived! Do something with it...
   '
End