PullSub

def __init__(
    self,
    batch_size: int = 1,
    timeout: Optional[float] = 5.0,
) -> None:
    super().__init__(
        batch_size=batch_size,
        timeout=timeout,
    )