Merge pull request #4 from mrk-its/aread_response_timeout

Handle timeout in aread_response

Author: sveinse

canopen/sdo/client.py

@@ -109,8 +109,9 @@ def read_response(self):
 
     async def aread_response(self):
         try:
-            response = await self.aresponses.get()
-        except queue.Empty:
+            response = await asyncio.wait_for(
+                self.aresponses.get(), timeout=self.RESPONSE_TIMEOUT)
+        except asyncio.TimeoutError:
             raise SdoCommunicationError("No SDO response received")
         res_command, = struct.unpack_from("B", response)
         if res_command == RESPONSE_ABORTED: