diff options
Diffstat (limited to 'restful_document/subscribe_socket.py')
| -rw-r--r-- | restful_document/subscribe_socket.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/restful_document/subscribe_socket.py b/restful_document/subscribe_socket.py index b73ce78..bd1e578 100644 --- a/restful_document/subscribe_socket.py +++ b/restful_document/subscribe_socket.py @@ -20,7 +20,7 @@ from gettext import gettext as _ from restful_document import env from restful_document.sockets import SocketFile, BUFFER_SIZE -from active_document import greenlet, util, enforce +from active_document import coroutine, util, enforce _logger = logging.getLogger('restful_document.subscribe_socket') @@ -48,13 +48,13 @@ class SubscribeSocket(object): _logger.info(_('Listening for subscriptions on %s port'), env.subscribe_port.value) - conn = greenlet.socket(socket.AF_INET, socket.SOCK_STREAM) + conn = coroutine.socket(socket.AF_INET, socket.SOCK_STREAM) # pylint: disable-msg=E1101 conn.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) conn.bind((env.host.value, env.subscribe_port.value)) conn.listen(5) - self._server = greenlet.Server(conn, self._serve_client) + self._server = coroutine.Server(conn, self._serve_client) try: env.subscriber = self self._server.serve_forever() |