Nats AsyncAPI obj schema test

airtai · Aug 3, 2024 · 2a2da68 · 2a2da68
1 parent 0e2a3c0
commit 2a2da68
Showing 1 changed file with 15 additions and 0 deletions.
diff --git a/tests/asyncapi/nats/v3_0_0/test_obj_schema.py b/tests/asyncapi/nats/v3_0_0/test_obj_schema.py
@@ -0,0 +1,15 @@
+from faststream import FastStream
+from faststream.asyncapi.generate import get_app_schema
+from faststream.asyncapi.version import AsyncAPIVersion
+from faststream.nats import NatsBroker
+
+
+def test_obj_schema():
+    broker = NatsBroker()
+
+    @broker.subscriber("test", obj_watch=True)
+    async def handle(): ...
+
+    schema = get_app_schema(FastStream(broker, asyncapi_version=AsyncAPIVersion.v3_0)).to_jsonable()
+
+    assert schema["channels"] == {}