diff --git a/icinga2apic/events.py b/icinga2apic/events.py
index bb07251..4e57c6c 100644
--- a/icinga2apic/events.py
+++ b/icinga2apic/events.py
@@ -82,5 +82,9 @@ def subscribe(self,
             payload,
             stream=True
         )
-        for event in self._get_message_from_stream(stream):
-            yield event
+
+        def gen():
+            for event in self._get_message_from_stream(stream):
+                yield event
+
+        return gen()