RedisPublisher

def __init__(
    self,
    channel: str | None = None,
    *,
    list: str | None = None,
    stream: str | None = None,
    headers: dict[str, Any] | None = None,
    reply_to: str = "",
    middlewares: Sequence["PublisherMiddleware"] = (),
    title: str | None = None,
    description: str | None = None,
    schema: Any | None = None,
    include_in_schema: bool = True,
) -> None:
    """Initialize the RedisPublisher.

    Args:
        channel:
            Redis PubSub object name to send message.
        list:
            Redis List object name to send message.
        stream:
            Redis Stream object name to send message.
        headers:
            Message headers to store metainformation. Can be overridden by `publish.headers` if specified.
        reply_to:
            Reply message destination PubSub object name.
        middlewares:
            Publisher middlewares to wrap outgoing messages.
        title:
            AsyncAPI publisher object title.
        description:
            AsyncAPI publisher object description.
        schema:
            AsyncAPI publishing message type.
        include_in_schema:
            Whetever to include operation in AsyncAPI schema or not.

    """
    super().__init__(
        channel=channel,
        list=list,
        stream=stream,
        headers=headers,
        reply_to=reply_to,
        middlewares=middlewares,
        title=title,
        description=description,
        schema=schema,
        include_in_schema=include_in_schema,
    )