fix: pass stream to concurrent subscribers

.github/workflows/pr_autoupdate.yaml

@@ -20,6 +20,8 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4.3.0
+        with:
+          persist-credentials: false
 
       - uses: astral-sh/setup-uv@e92bafb6253dcd438e0484186d7669ea7a8ca1cc # v6.4.3
         with:
@@ -54,4 +56,4 @@ jobs:
       # the application uses this to find the right workflow.
       - name: Run pre-commit-ci-lite
         uses: pre-commit-ci/lite-action@5d6cc0eb514c891a40562a58a8e71576c5c7fb43 # v1.1.0
-        if: always()
+        if: always()

faststream/nats/subscriber/factory.py

@@ -222,14 +222,17 @@ def create_subscriber(
         if pull_sub is not None:
             return ConcurrentPullStreamSubscriber(
                 **subscriber_options,
-                queue=queue,
                 max_workers=max_workers,
+                queue=queue,
+                stream=stream,
                 pull_sub=pull_sub,
             )
 
         return ConcurrentPushStreamSubscriber(
             **subscriber_options,
             max_workers=max_workers,
+            queue=queue,
+            stream=stream,
         )
 
     if pull_sub is not None:

pyproject.toml

@@ -1,5 +1,5 @@
 [build-system]
-requires = ["uv_build>=0.7.19,<0.9.0"]
+requires = ["uv_build>=0.8.4,<0.9.0"]
 build-backend = "uv_build"
 
 [project]

tests/asyncapi/base/v2_6_0/arguments.py

@@ -426,6 +426,7 @@ def test_nested_models_in_union_should_be_in_schemas(self) -> None:
         Fixes issue #2443: Nested Pydantic models are not included in AsyncAPI
         components/schemas (inplaced instead).
         """
+
         class Email(pydantic.BaseModel):
             addr: str
 
@@ -461,6 +462,7 @@ def test_nested_models_in_publisher_union_should_be_in_schemas(self) -> None:
         Fixes issue #2443: Nested Pydantic models are not included in AsyncAPI
         components/schemas (inplaced instead).
         """
+
         class Email(pydantic.BaseModel):
             addr: str
 

tests/asyncapi/base/v3_0_0/arguments.py

@@ -390,6 +390,7 @@ def test_nested_models_in_union_should_be_in_schemas(self) -> None:
         Fixes issue #2443: Nested Pydantic models are not included in AsyncAPI
         components/schemas (inplaced instead).
         """
+
         class Email(pydantic.BaseModel):
             addr: str
 
@@ -425,6 +426,7 @@ def test_nested_models_in_publisher_union_should_be_in_schemas(self) -> None:
         Fixes issue #2443: Nested Pydantic models are not included in AsyncAPI
         components/schemas (inplaced instead).
         """
+
         class Email(pydantic.BaseModel):
             addr: str