diff --git a/qubesadmin/events/__init__.py b/qubesadmin/events/__init__.py
index a10f16f..375f31d 100644
--- a/qubesadmin/events/__init__.py
+++ b/qubesadmin/events/__init__.py
@@ -173,6 +173,8 @@ class EventsDispatcher(object):
                         value = (yield from reader.readuntil(b'\0'))[:-1].\
                             decode('utf-8')
                         kwargs[key] = value
+                except BrokenPipeError:
+                    break
                 except asyncio.IncompleteReadError as err:
                     if err.partial == b'':
                         break