Skip to content

Commit

Permalink
blocking_connection: Fix consume() return type
Browse files Browse the repository at this point in the history
Signed-off-by: Anders Kaseorg <[email protected]>
  • Loading branch information
andersk committed Aug 3, 2021
1 parent 361dc1a commit ded3038
Showing 1 changed file with 8 additions and 2 deletions.
10 changes: 8 additions & 2 deletions pika-stubs/adapters/blocking_connection.pyi
Original file line number Diff line number Diff line change
@@ -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

Expand Down Expand Up @@ -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: ...

Expand Down

0 comments on commit ded3038

Please sign in to comment.