Merge pull request gvalkov#53 from paulo-raca/read_loop

gvalkov · gvalkov · commit 2e0b19d0ce7f · 2016-02-07T00:07:18.000+01:00
async version of `read_loop()` must stop on errors.
diff --git a/evdev/eventio_async.py b/evdev/eventio_async.py
@@ -76,7 +76,10 @@ def __anext__(self):
             future.set_result(next(self.current_batch))
         except StopIteration:
             def next_batch_ready(batch):
-                self.current_batch = batch.result()
-                future.set_result(next(self.current_batch))
+                try:
+                    self.current_batch = batch.result()
+                    future.set_result(next(self.current_batch))
+                except Exception as e:
+                    future.set_exception(e)
             self.device.async_read().add_done_callback(next_batch_ready)
         return future
