StreamSub

def __init__(
    self,
    stream: str,
    polling_interval: int | None = None,
    group: str | None = None,
    consumer: str | None = None,
    batch: bool = False,
    no_ack: bool = False,
    last_id: str | None = None,
    maxlen: int | None = None,
    max_records: int | None = None,
    min_idle_time: int | None = None,
    declare: bool = True,
    claim_min_idle_time: int | None = None,
) -> None:
    if (group and not consumer) or (not group and consumer):
        msg = "You should specify `group` and `consumer` both"
        raise SetupError(msg)

    if not declare and not group:
        warnings.warn(
            message="`declare` has no effect without consumer group",
            category=RuntimeWarning,
            stacklevel=1,
        )

    if last_id is None:
        last_id = ">" if group and consumer else "$"

    if group and consumer and last_id != ">":
        if polling_interval:
            warnings.warn(
                message="`polling_interval` is not supported by consumer group with last_id other than `>`",
                category=RuntimeWarning,
                stacklevel=1,
            )

        if no_ack:
            warnings.warn(
                message="`no_ack` is not supported by consumer group with last_id other than `>`",
                category=RuntimeWarning,
                stacklevel=1,
            )

    if claim_min_idle_time is not None:
        if not REDIS_V710:
            msg = (
                "`claim_min_idle_time` requires redis-py 7.1.0 or newer "
                f"(installed: {_REDIS_VERSION})"
            )
            raise SetupError(msg)

        if min_idle_time is not None:
            msg = (
                "`claim_min_idle_time` (XREADGROUP CLAIM) and `min_idle_time` "
                "(XAUTOCLAIM) are mutually exclusive"
            )
            raise SetupError(msg)

        if no_ack:
            msg = (
                "`claim_min_idle_time` with `no_ack` causes infinite "
                "redelivery: claimed entries stay in the PEL and are "
                "never acknowledged"
            )
            raise SetupError(msg)

        if not group:
            msg = "`claim_min_idle_time` requires `group` and `consumer`"
            raise SetupError(msg)

        if last_id != ">":
            msg = (
                "`claim_min_idle_time` requires last_id `>`: Redis ignores "
                "the CLAIM option for any other id"
            )
            raise SetupError(msg)

    super().__init__(stream)

    self.group = group
    self.consumer = consumer
    self.declare = declare
    self.polling_interval = polling_interval or 100
    self.batch = batch
    self.no_ack = no_ack
    self.last_id = last_id
    self.maxlen = maxlen
    self.max_records = max_records
    self.min_idle_time = min_idle_time
    self.claim_min_idle_time = claim_min_idle_time