# test asynchat -- requires threading
import thread
# If this fails, we can't test this module
import asyncore
, asynchat
, socket
, threading
, time
class echo_server(threading
.Thread
):
sock
= socket
.socket(socket
.AF_INET
, socket
.SOCK_STREAM
)
sock
.setsockopt(socket
.SOL_SOCKET
, socket
.SO_REUSEADDR
, 1)
conn
, client
= sock
.accept()
while "\n" not in buffer:
class echo_client(asynchat
.async_chat
):
asynchat
.async_chat
.__init
__(self
)
self
.create_socket(socket
.AF_INET
, socket
.SOCK_STREAM
)
self
.connect((HOST
, PORT
))
self
.set_terminator("\n")
def handle_connect(self
):
def collect_incoming_data(self
, data
):
self
.buffer = self
.buffer + data
def found_terminator(self
):
print "Received:", repr(self
.buffer)
time
.sleep(1) # Give server time to initialize