asyncio server coroutine style

asyncserv.py

import asyncio

def block_read_from_database():
    result = yield from asyncio.sleep(1, b'OK')
    return result


class Protocol(asyncio.Protocol):

    def connection_made(self, transport):
        self._transport = transport

    def data_received(self, data):
        asyncio.async(self.response(data))

    def response(self, data):
        '''This is the coroutine which handle the response
        '''
        result = yield from block_read_from_database()
        self._transport.write(result)


loop = asyncio.get_event_loop()
asyncio.async(loop.create_server(Protocol, '127.0.0.1', 3000), loop=loop)
loop.run_forever()