Replaced StreamServer with ChannelServer

setup.py

@@ -1,7 +1,7 @@
 from setuptools import setup
 from setuptools.extension import Extension
 
-modules = ['ropebuffer', 'broadcast', 'channel', 'messenger', 'streamserver']
+modules = ['ropebuffer', 'broadcast', 'channel', 'messenger']
 
 extensions = [Extension(
 	name ='socketless.%s' % module,

socketless/__init__.py

@@ -1,6 +1,6 @@
-__all__ = ['ropebuffer', 'channel', 'messenger', 'broadcast', 'streamserver']
+__all__ = ['ropebuffer', 'channel', 'messenger', 'broadcast', 'channelserver']
 
 import ropebuffer
 import messenger
-import streamserver
+import channelserver
 import broadcast

socketless/channelserver.py

@@ -0,0 +1,36 @@
+import socket
+
+from syncless import coio
+
+from channel import Channel
+
+class ChannelServer(object):
+	"""docstring for ChannelServer"""
+	def __init__(self, listener, handle_connection=None, listen_backlog=1024):
+		super(ChannelServer, self).__init__()
+		self.listening_tasklet = None
+		self.listening_socket = None
+		self.listen_backlog = listen_backlog
+		self.listener = listener
+		if handle_connection:
+			self.handle_connection = handle_connection
+
+	def serve(self):
+		self.listening_tasklet = coio.stackless.tasklet(self._serve)()
+
+	def _serve(self):
+		self.listening_socket = coio.nbsocket(socket.AF_INET, socket.SOCK_STREAM)
+		self.listening_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+		self.listening_socket.bind(self.listener)
+		self.listening_socket.listen(self.listen_backlog)
+		while True:
+			conn, addr = self.listening_socket.accept()
+			coio.stackless.tasklet(self.handle_connection)(Channel(conn), addr)
+			coio.stackless.schedule()
+
+	def stop(self):
+		self.listening_tasklet.kill()
+		self.listening_tasklet = None
+
+	def serve_forever(self):
+		self._serve()