8003: user nginx; worker_processes 1; error_log /var/log/nginx/error.log; pid /var/run/nginx.pid; events { worker_connections 1024; use epoll; } http { # Enumerate all the Tornado servers here Asynchronous networking tornado.ioloop — Main event loop IOLoop objects Running an IOLoop I/O events Callbacks and timeouts tornado.iostream — Convenient wrappers for non-blocking sockets Base class read_until_close() print("message from client:", message.decode().strip()) def connection_ready(sock, fd, events): while True: try: connection, address = sock.accept() except BlockingIOError:

8003: user nginx; worker_processes 1; error_log /var/log/nginx/error.log; pid /var/run/nginx.pid; events { worker_connections 1024; use epoll; } http { # Enumerate all the Tornado servers here Asynchronous networking tornado.ioloop — Main event loop IOLoop objects Running an IOLoop I/O events Callbacks and timeouts tornado.iostream — Convenient wrappers for non-blocking sockets Base class read_until_close() print("message from client:", message.decode().strip()) def connection_ready(sock, fd, events): while True: try: connection, address = sock.accept() except socket

8003: user nginx; worker_processes 1; error_log /var/log/nginx/error.log; pid /var/run/nginx.pid; events { worker_connections 1024; use epoll; } http { # Enumerate all the Tornado servers here Asynchronous networking tornado.ioloop — Main event loop IOLoop objects Running an IOLoop I/O events Callbacks and timeouts Debugging and error handling Methods for subclasses tornado.iostream — Convenient org/3.5/library/unittest.html#module-unittest] case. In addition to I/O events, the IOLoop can also schedule time-based events. IOLoop.add_timeout is a non-blocking alternative to time.sleep [https://docs

1.1 (continued from previous page) error_log /var/log/nginx/error.log; pid /var/run/nginx.pid; events { worker_connections 1024; use epoll; } http { # Enumerate all the Tornado servers here upstream Asynchronous networking 93 Tornado Documentation, Release 5.1.1 In addition to I/O events, the IOLoop can also schedule time-based events. IOLoop.add_timeout is a non- blocking alternative to time.sleep. IOLoop read_until_close() print("message from client:", message.decode().strip()) def connection_ready(sock, fd, events): while True: try: connection, address = sock.accept() except socket.error as e: if e.args[0]

8003: user nginx; worker_processes 1; error_log /var/log/nginx/error.log; pid /var/run/nginx.pid; events { worker_connections 1024; use epoll; } http { # Enumerate all the Tornado servers here Asynchronous networking tornado.ioloop — Main event loop IOLoop objects Running an IOLoop I/O events Callbacks and timeouts Debugging and error handling Methods for subclasses tornado.iostream — Convenient org/3.6/library/unittest.html#module-unittest] case. In addition to I/O events, the IOLoop can also schedule time-based events. IOLoop.add_timeout is a non-blocking alternative to time.sleep [https://docs

8003: user nginx; worker_processes 1; error_log /var/log/nginx/error.log; pid /var/run/nginx.pid; events { worker_connections 1024; (continues on next page) 6.1. User’s guide 35 Tornado Documentation read_until_close() print("message from client:", message.decode().strip()) def connection_ready(sock, fd, events): while True: try: connection, address = sock.accept() (continues on next page) 96 Chapter 6 5.0. I/O events IOLoop.add_handler(fd: Union[int, tornado.ioloop._Selectable], handler: Callable[[...], None], events: int) → None Registers the given handler to receive the given events for fd. The

8003: user nginx; worker_processes 1; error_log /var/log/nginx/error.log; pid /var/run/nginx.pid; events { worker_connections 1024; use epoll; } http { # Enumerate all the Tornado servers here upstream such as one IOLoop per thread, or per unittest case. In addition to I/O events, the IOLoop can also schedule time-based events. IOLoop.add_timeout is a non- blocking alternative to time.sleep. IOLoop import errno import functools import tornado.ioloop import socket def connection_ready(sock, fd, events): while True: try: connection, address = sock.accept() except socket.error as e: if e.args[0]

8003: user nginx; worker_processes 1; error_log /var/log/nginx/error.log; pid /var/run/nginx.pid; events { worker_connections 1024; use epoll; } http { # Enumerate all the Tornado servers here upstream read_until_close() print("message from client:", message.decode().strip()) def connection_ready(sock, fd, events): while True: try: connection, address = sock.accept() except socket.error as e: if e.args[0] 5.0. I/O events IOLoop.add_handler(fd: Union[int, tornado.ioloop._Selectable], handler: Callable[[...], None], events: int) → None Registers the given handler to receive the given events for fd. The

8003: user nginx; worker_processes 1; error_log /var/log/nginx/error.log; pid /var/run/nginx.pid; events { worker_connections 1024; use epoll; } http { # Enumerate all the Tornado servers here upstream read_until_close() print("message from client:", message.decode().strip()) def connection_ready(sock, fd, events): while True: try: connection, address = sock.accept() except BlockingIOError: return connection since version 5.0. I/O events IOLoop.add_handler(fd: int, handler: Callable[[int, int], None], events: int) → None IOLoop.add_handler(fd: _S, handler: Callable[[_S, int], None], events: int) → None Registers

8003: user nginx; worker_processes 1; error_log /var/log/nginx/error.log; pid /var/run/nginx.pid; events { worker_connections 1024; use epoll; } http { # Enumerate all the Tornado servers here upstream read_until_close() print("message from client:", message.decode().strip()) def connection_ready(sock, fd, events): while True: try: connection, address = sock.accept() except BlockingIOError: return connection version 5.0. I/O events IOLoop.add_handler(fd: int, handler: Callable[[int, int], None], events: int) → None IOLoop.add_handler(fd: _S, handler: Callable[[_S, int], None], events: int) → None Registers