blocking_connection: Fix consume() return type

Fixes hahow#3. Signed-off-by: Anders Kaseorg <[email protected]>
andersk · Aug 10, 2021 · a9dd0fb · a9dd0fb
1 parent 361dc1a
commit a9dd0fb
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/pika-stubs/adapters/blocking_connection.pyi b/pika-stubs/adapters/blocking_connection.pyi
@@ -1,7 +1,7 @@
 from __future__ import annotations
 
 import types
-from typing import Any, Callable, List, Mapping, Optional, Tuple, Type
+from typing import Any, Callable, Iterator, List, Mapping, Optional, Tuple, Type
 
 from .. import channel, connection, frame, spec
 
@@ -147,7 +147,13 @@ class BlockingChannel:
         exclusive: bool = ...,
         arguments: Optional[Mapping[str, Any]] = ...,
         inactivity_timeout: Optional[float] = ...,
-    ) -> None: ...
+    ) -> Iterator[
+        Tuple[
+            Optional[spec.Basic.Deliver],
+            Optional[spec.BasicProperties],
+            Optional[bytes],
+        ]
+    ]: ...
 
     def get_waiting_message_count(self) -> int: ...