diff --git a/platypush/plugins/ntfy/__init__.py b/platypush/plugins/ntfy/__init__.py
index 9610b31a..a7eddbad 100644
--- a/platypush/plugins/ntfy/__init__.py
+++ b/platypush/plugins/ntfy/__init__.py
@@ -93,8 +93,8 @@ class NtfyPlugin(AsyncRunnablePlugin):
                 )
 
     async def listen(self):
-        return await asyncio.wait(
-            [
+        return await asyncio.gather(
+            *[
                 self._get_ws_handler(f'{self._ws_url}/{sub}/ws')
                 for sub in set(self._subscriptions)
             ]