airtai · Lancetnik · Nov 26, 2024 · Nov 14, 2024 · Nov 14, 2024 · Nov 19, 2024
diff --git a/docs/docs/SUMMARY.md b/docs/docs/SUMMARY.md
diff --git a/...ststream/kafka/subscriber/specified/SpecificationConcurrentDefaultSubscriber.md b/...ststream/kafka/subscriber/specified/SpecificationConcurrentDefaultSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.kafka.subscriber.specified.SpecificationConcurrentDefaultSubscriber
diff --git a/.../docs/en/api/faststream/kafka/subscriber/usecase/ConcurrentDefaultSubscriber.md b/.../docs/en/api/faststream/kafka/subscriber/usecase/ConcurrentDefaultSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.kafka.subscriber.usecase.ConcurrentDefaultSubscriber
diff --git a/...i/faststream/redis/message/ListMessage.md → docs/docs/en/api/faststream/nats/PubAck.md b/...i/faststream/redis/message/ListMessage.md → docs/docs/en/api/faststream/nats/PubAck.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.redis.message.ListMessage
+::: nats.js.api.PubAck
diff --git a/...faststream/redis/message/StreamMessage.md → .../en/api/faststream/nats/schemas/PubAck.md b/...faststream/redis/message/StreamMessage.md → .../en/api/faststream/nats/schemas/PubAck.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.redis.message.StreamMessage
+::: nats.js.api.PubAck
diff --git a/docs/docs/en/api/faststream/nats/subscriber/usecases/BatchPullStreamSubscriber.md b/docs/docs/en/api/faststream/nats/subscriber/usecases/BatchPullStreamSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.BatchPullStreamSubscriber
diff --git a/...iber/usecase/BatchPullStreamSubscriber.md → ...iber/usecases/ConcurrentCoreSubscriber.md b/...iber/usecase/BatchPullStreamSubscriber.md → ...iber/usecases/ConcurrentCoreSubscriber.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.nats.subscriber.usecase.BatchPullStreamSubscriber
+::: faststream.nats.subscriber.usecases.ConcurrentCoreSubscriber
diff --git a/...cs/en/api/faststream/nats/subscriber/usecases/ConcurrentPullStreamSubscriber.md b/...cs/en/api/faststream/nats/subscriber/usecases/ConcurrentPullStreamSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.ConcurrentPullStreamSubscriber
diff --git a/...cs/en/api/faststream/nats/subscriber/usecases/ConcurrentPushStreamSubscriber.md b/...cs/en/api/faststream/nats/subscriber/usecases/ConcurrentPushStreamSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.ConcurrentPushStreamSubscriber
diff --git a/...ats/subscriber/usecase/LogicSubscriber.md → ...ats/subscriber/usecases/CoreSubscriber.md b/...ats/subscriber/usecase/LogicSubscriber.md → ...ats/subscriber/usecases/CoreSubscriber.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.nats.subscriber.usecase.LogicSubscriber
+::: faststream.nats.subscriber.usecases.CoreSubscriber
diff --git a/...riber/usecase/ConcurrentCoreSubscriber.md → ...riber/usecases/KeyValueWatchSubscriber.md b/...riber/usecase/ConcurrentCoreSubscriber.md → ...riber/usecases/KeyValueWatchSubscriber.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.nats.subscriber.usecase.ConcurrentCoreSubscriber
+::: faststream.nats.subscriber.usecases.KeyValueWatchSubscriber
diff --git a/docs/docs/en/api/faststream/nats/subscriber/usecases/LogicSubscriber.md b/docs/docs/en/api/faststream/nats/subscriber/usecases/LogicSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.LogicSubscriber
diff --git a/docs/docs/en/api/faststream/nats/subscriber/usecases/ObjStoreWatchSubscriber.md b/docs/docs/en/api/faststream/nats/subscriber/usecases/ObjStoreWatchSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.ObjStoreWatchSubscriber
diff --git a/docs/docs/en/api/faststream/nats/subscriber/usecases/PullStreamSubscriber.md b/docs/docs/en/api/faststream/nats/subscriber/usecases/PullStreamSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.PullStreamSubscriber
diff --git a/...criber/usecase/ObjStoreWatchSubscriber.md → ...criber/usecases/PushStreamSubscription.md b/...criber/usecase/ObjStoreWatchSubscriber.md → ...criber/usecases/PushStreamSubscription.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.nats.subscriber.usecase.ObjStoreWatchSubscriber
+::: faststream.nats.subscriber.usecases.PushStreamSubscription
diff --git a/docs/docs/en/api/faststream/nats/subscriber/usecases/basic/DefaultSubscriber.md b/docs/docs/en/api/faststream/nats/subscriber/usecases/basic/DefaultSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.basic.DefaultSubscriber
diff --git a/...scriber/usecase/PushStreamSubscription.md → ...scriber/usecases/basic/LogicSubscriber.md b/...scriber/usecase/PushStreamSubscription.md → ...scriber/usecases/basic/LogicSubscriber.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.nats.subscriber.usecase.PushStreamSubscription
+::: faststream.nats.subscriber.usecases.basic.LogicSubscriber
diff --git a/...faststream/nats/subscriber/usecases/core_subscriber/ConcurrentCoreSubscriber.md b/...faststream/nats/subscriber/usecases/core_subscriber/ConcurrentCoreSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.core_subscriber.ConcurrentCoreSubscriber
diff --git a/...cs/en/api/faststream/nats/subscriber/usecases/core_subscriber/CoreSubscriber.md b/...cs/en/api/faststream/nats/subscriber/usecases/core_subscriber/CoreSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.core_subscriber.CoreSubscriber
diff --git a/...stream/nats/subscriber/usecases/key_value_subscriber/KeyValueWatchSubscriber.md b/...stream/nats/subscriber/usecases/key_value_subscriber/KeyValueWatchSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.key_value_subscriber.KeyValueWatchSubscriber
diff --git a/...m/nats/subscriber/usecases/object_storage_subscriber/ObjStoreWatchSubscriber.md b/...m/nats/subscriber/usecases/object_storage_subscriber/ObjStoreWatchSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.object_storage_subscriber.ObjStoreWatchSubscriber
diff --git a/...usecase/ConcurrentPullStreamSubscriber.md → ...usecases/stream_basic/StreamSubscriber.md b/...usecase/ConcurrentPullStreamSubscriber.md → ...usecases/stream_basic/StreamSubscriber.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.nats.subscriber.usecase.ConcurrentPullStreamSubscriber
+::: faststream.nats.subscriber.usecases.stream_basic.StreamSubscriber
diff --git a/...am/nats/subscriber/usecases/stream_pull_subscriber/BatchPullStreamSubscriber.md b/...am/nats/subscriber/usecases/stream_pull_subscriber/BatchPullStreamSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.stream_pull_subscriber.BatchPullStreamSubscriber
diff --git a/...ts/subscriber/usecases/stream_pull_subscriber/ConcurrentPullStreamSubscriber.md b/...ts/subscriber/usecases/stream_pull_subscriber/ConcurrentPullStreamSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.stream_pull_subscriber.ConcurrentPullStreamSubscriber
diff --git a/...tstream/nats/subscriber/usecases/stream_pull_subscriber/PullStreamSubscriber.md b/...tstream/nats/subscriber/usecases/stream_pull_subscriber/PullStreamSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.stream_pull_subscriber.PullStreamSubscriber
diff --git a/...ts/subscriber/usecases/stream_push_subscriber/ConcurrentPushStreamSubscriber.md b/...ts/subscriber/usecases/stream_push_subscriber/ConcurrentPushStreamSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.stream_push_subscriber.ConcurrentPushStreamSubscriber
diff --git a/...tream/nats/subscriber/usecases/stream_push_subscriber/PushStreamSubscription.md b/...tream/nats/subscriber/usecases/stream_push_subscriber/PushStreamSubscription.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.nats.subscriber.usecases.stream_push_subscriber.PushStreamSubscription
diff --git a/docs/docs/en/api/faststream/prometheus/middleware/BasePrometheusMiddleware.md b/docs/docs/en/api/faststream/prometheus/middleware/BasePrometheusMiddleware.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.prometheus.middleware.BasePrometheusMiddleware
diff --git a/...criber/usecase/KeyValueWatchSubscriber.md → ...tion/asyncapi/utils/move_pydantic_refs.md b/...criber/usecase/KeyValueWatchSubscriber.md → ...tion/asyncapi/utils/move_pydantic_refs.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.nats.subscriber.usecase.KeyValueWatchSubscriber
+::: faststream.specification.asyncapi.utils.move_pydantic_refs
diff --git a/.../en/api/faststream/specification/asyncapi/v2_6_0/generate/move_pydantic_refs.md b/.../en/api/faststream/specification/asyncapi/v2_6_0/generate/move_pydantic_refs.md
diff --git a/.../docs/en/api/faststream/specification/asyncapi/v2_6_0/schema/ApplicationInfo.md b/.../docs/en/api/faststream/specification/asyncapi/v2_6_0/schema/ApplicationInfo.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.specification.asyncapi.v2_6_0.schema.ApplicationInfo
diff --git a/...usecase/ConcurrentPushStreamSubscriber.md → ...yncapi/v2_6_0/schema/ApplicationSchema.md b/...usecase/ConcurrentPushStreamSubscriber.md → ...yncapi/v2_6_0/schema/ApplicationSchema.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.nats.subscriber.usecase.ConcurrentPushStreamSubscriber
+::: faststream.specification.asyncapi.v2_6_0.schema.ApplicationSchema
diff --git a/docs/docs/en/api/faststream/specification/asyncapi/v2_6_0/schema/Info.md b/docs/docs/en/api/faststream/specification/asyncapi/v2_6_0/schema/Info.md
diff --git a/docs/docs/en/api/faststream/specification/asyncapi/v2_6_0/schema/Schema.md b/docs/docs/en/api/faststream/specification/asyncapi/v2_6_0/schema/Schema.md
diff --git a/...tstream/specification/asyncapi/v2_6_0/schema/bindings/amqp/channel/from_spec.md b/...tstream/specification/asyncapi/v2_6_0/schema/bindings/amqp/channel/from_spec.md
diff --git a/...specification/asyncapi/v2_6_0/schema/bindings/amqp/channel_binding_from_spec.md b/...specification/asyncapi/v2_6_0/schema/bindings/amqp/channel_binding_from_spec.md
diff --git a/...tream/specification/asyncapi/v2_6_0/schema/bindings/amqp/operation/from_spec.md b/...tream/specification/asyncapi/v2_6_0/schema/bindings/amqp/operation/from_spec.md
diff --git a/...ecification/asyncapi/v2_6_0/schema/bindings/amqp/operation_binding_from_spec.md b/...ecification/asyncapi/v2_6_0/schema/bindings/amqp/operation_binding_from_spec.md
diff --git a/...ream/specification/asyncapi/v2_6_0/schema/bindings/channel_binding_from_spec.md b/...ream/specification/asyncapi/v2_6_0/schema/bindings/channel_binding_from_spec.md