From 9d769d9034d4b81b3fb6cbde0dc044a4d3e68379 Mon Sep 17 00:00:00 2001 From: DoubleHomixide Date: Sun, 5 Jan 2025 03:09:55 +0300 Subject: [PATCH] test: add new overload --- faststream/redis/broker/broker.py | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) diff --git a/faststream/redis/broker/broker.py b/faststream/redis/broker/broker.py index c98ed811ab..f5d0a7d04c 100644 --- a/faststream/redis/broker/broker.py +++ b/faststream/redis/broker/broker.py @@ -372,13 +372,27 @@ def _subscriber_setup_extra(self) -> "AnyDict": async def publish( # type: ignore[override] self, message: "SendableMessage" = None, + channel: None = None, + *, + reply_to: str = "", + headers: Optional["AnyDict"] = None, + correlation_id: Optional[str] = None, + list: Optional[str] = None, + stream: Optional[str] = None, + maxlen: Optional[int] = None, + ) -> None: ... + + @overload + async def publish( # type: ignore[override] + self, + message: None = None, channel: Optional[str] = None, *, reply_to: str = "", headers: Optional["AnyDict"] = None, correlation_id: Optional[str] = None, list: Optional[str] = None, - stream: None = None, + stream: Optional[str] = None, maxlen: Optional[int] = None, ) -> None: ...