from twisted.internet import reactor
from twisted.protocols.basic import LineReceiver
from twisted.internet.protocol import ClientFactory

class Tester(LineReceiver):
    def connectionMade(self):
	print "pushing data"
	self.transport.write("1" * 128)
	self.transport.write("2" * 128)
	self.transport.write("3" * 128)
	self.transport.write("4" * 128)
    def lineReceived(self, line):
	print "got", repr(line)

a = ClientFactory()
a.protocol = Tester
	
reactor.callLater(5, reactor.stop)
reactor.connectTCP("localhost", 31337, a)
reactor.run()