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)