fix: use async test subscribers functions (#1725)

airtai · Aug 24, 2024 · 5e52cf3 · 5e52cf3
1 parent 32b697f
commit 5e52cf3
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/faststream/confluent/testing.py b/faststream/confluent/testing.py
@@ -66,7 +66,7 @@ def create_publisher_fake_subscriber(
         if not sub.calls:
 
             @sub  # type: ignore[misc]
-            def publisher_response_subscriber(msg: Any) -> None:
+            async def publisher_response_subscriber(msg: Any) -> None:
                 pass
 
             broker.setup_subscriber(sub)

diff --git a/faststream/kafka/testing.py b/faststream/kafka/testing.py
@@ -55,7 +55,7 @@ def create_publisher_fake_subscriber(
         if not sub.calls:
 
             @sub  # type: ignore[misc]
-            def publisher_response_subscriber(msg: Any) -> None:
+            async def publisher_response_subscriber(msg: Any) -> None:
                 pass
 
             broker.setup_subscriber(sub)

diff --git a/faststream/nats/testing.py b/faststream/nats/testing.py
@@ -33,7 +33,7 @@ def create_publisher_fake_subscriber(
         if not sub.calls:
 
             @sub
-            def publisher_response_subscriber(msg: Any) -> None:
+            async def publisher_response_subscriber(msg: Any) -> None:
                 pass
 
             broker.setup_subscriber(sub)

diff --git a/faststream/rabbit/testing.py b/faststream/rabbit/testing.py
@@ -66,7 +66,7 @@ def create_publisher_fake_subscriber(
         if not sub.calls:
 
             @sub
-            def publisher_response_subscriber(msg: Any) -> None:
+            async def publisher_response_subscriber(msg: Any) -> None:
                 pass
 
             broker.setup_subscriber(sub)

diff --git a/faststream/redis/testing.py b/faststream/redis/testing.py
@@ -43,7 +43,7 @@ def create_publisher_fake_subscriber(
         if not sub.calls:
 
             @sub
-            def publisher_response_subscriber(msg: Any) -> None:
+            async def publisher_response_subscriber(msg: Any) -> None:
                 pass
 
             broker.setup_subscriber(sub)