task = asyncio.async(self.go())
task.add_done_callback(self.handle_go_result)

def handle_go_result(self, task):
    data = task.result()
self.send(data)
Вызов сопрограммы из asyncio.Protocol.data_received