From 0671c504aee3f70ddf91fcfdb29ae5ac6efe0d96 Mon Sep 17 00:00:00 2001
From: Jonas Zeunert <jonas@zeunert.org>
Date: Thu, 13 Feb 2020 21:58:15 +0100
Subject: [PATCH] asyncio

---
 Game.py                  | 3 ++-
 InputHandler.py          | 3 ++-
 networking/Networking.py | 4 +++-
 3 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/Game.py b/Game.py
index 776e16e..630e947 100644
--- a/Game.py
+++ b/Game.py
@@ -15,7 +15,8 @@ class Game:
         print('Received SIGINT. Stopping Game :-)')
         self.is_running.release()
 
-    async def run(self):
+    @asyncio.coroutine
+    def run(self):
         self.is_running.acquire()
         asyncio.run(self.input_handler.handleInputs())
 
diff --git a/InputHandler.py b/InputHandler.py
index be1d7f4..934b957 100644
--- a/InputHandler.py
+++ b/InputHandler.py
@@ -7,7 +7,8 @@ class InputHandler:
         self.isRunning = True
         self.targets = targets
 
-    async def handleInputs(self):
+    @asyncio.coroutine
+    def handleInputs(self):
         self.isRunning = True
         while self.isRunning:
             event = await Networking().getInputEvent()
diff --git a/networking/Networking.py b/networking/Networking.py
index 4ee4908..a4d5a46 100644
--- a/networking/Networking.py
+++ b/networking/Networking.py
@@ -1,5 +1,6 @@
 import requests_unixsocket as req
 import socket
+import asyncio
 from utils.Singleton import Singleton
 
 
@@ -47,7 +48,8 @@ class Networking(metaclass=Singleton):
     def writeDisplayScore(self, display, score):
         self.get("/displays/" + display + "/write_score/" + str(score))
 
-    async def getInputEvent(self):
+    @asyncio.coroutine
+    def getInputEvent(self):
         header = list()
         while b'\x02' not in header:
             byte = self.input_socket.recv(1)