Merge branch 'main' into doc-2220

Author: Lancetnik

docs/docs/en/getting-started/serialization/decoder.md

@@ -66,7 +66,7 @@ Alternatively, you can reuse the original decoder function with the following si
 
 === "AIOKafka"
     ```python
-    from types import Callable, Awaitable
+    from typing import Callable, Awaitable
     from faststream.types import DecodedMessage
     from faststream.kafka import KafkaMessage
 
@@ -79,7 +79,7 @@ Alternatively, you can reuse the original decoder function with the following si
 
 === "Confluent"
     ```python
-    from types import Callable, Awaitable
+    from typing import Callable, Awaitable
     from faststream.types import DecodedMessage
     from faststream.confluent import KafkaMessage
 
@@ -92,7 +92,7 @@ Alternatively, you can reuse the original decoder function with the following si
 
 === "RabbitMQ"
     ```python
-    from types import Callable, Awaitable
+    from typing import Callable, Awaitable
     from faststream.types import DecodedMessage
     from faststream.rabbit import RabbitMessage
 
@@ -105,7 +105,7 @@ Alternatively, you can reuse the original decoder function with the following si
 
 === "NATS"
     ```python
-    from types import Callable, Awaitable
+    from typing import Callable, Awaitable
     from faststream.types import DecodedMessage
     from faststream.nats import NatsMessage
 
@@ -118,7 +118,7 @@ Alternatively, you can reuse the original decoder function with the following si
 
 === "Redis"
     ```python
-    from types import Callable, Awaitable
+    from typing import Callable, Awaitable
     from faststream.types import DecodedMessage
     from faststream.redis import RedisMessage
 

docs/docs/en/getting-started/serialization/index.md

@@ -21,9 +21,9 @@ Before the message reaches your subscriber, **FastStream** applies two functions
 At this stage, **FastStream** serializes an incoming message from the broker's framework into a general format called - **StreamMessage**. During this stage, the message body remains in the form of raw bytes.
 
 !!! warning ""
-    This stage is closely related to the features of the broker used, and in most cases, redefining it is not necessary.
+    This stage is closely related to the features of the used broker, and in most cases, redefining it is not necessary. Redefine it, only if you know what you are doing.
 
-The parser declared at the `broker` level will be applied to all subscribers. The parser declared at the `subscriber` level is applied only to that specific subscriber and overrides the `broker' parser if specified.
+The parser declared at the `broker` level will be applied to all subscribers. The parser declared at the `subscriber` level is applied only to that specific subscriber and overrides the `broker`'s parser if specified.
 
 ### Message Decoding
 

docs/docs/en/getting-started/serialization/parser.md

@@ -69,7 +69,7 @@ Alternatively, you can reuse the original parser function with the following sig
 
 === "AIOKafka"
     ```python
-    from types import Callable, Awaitable
+    from typing import Callable, Awaitable
     from faststream.kafka import ConsumerRecord, KafkaMessage
 
     async def parser(
@@ -82,7 +82,7 @@ Alternatively, you can reuse the original parser function with the following sig
 === "Confluent"
     ```python
     from confluent_kafka import Message
-    from types import Callable, Awaitable
+    from typing import Callable, Awaitable
     from faststream.confluent import KafkaMessage
 
     async def parser(
@@ -94,7 +94,7 @@ Alternatively, you can reuse the original parser function with the following sig
 
 === "RabbitMQ"
     ```python
-    from types import Callable, Awaitable
+    from typing import Callable, Awaitable
     from aio_pika import IncomingMessage
     from faststream.rabbit import RabbitMessage
 
@@ -107,7 +107,7 @@ Alternatively, you can reuse the original parser function with the following sig
 
 === "NATS"
     ```python
-    from types import Callable, Awaitable
+    from typing import Callable, Awaitable
     from nats.aio.msg import Msg
     from faststream.nats import NatsMessage
 
@@ -120,7 +120,7 @@ Alternatively, you can reuse the original parser function with the following sig
 
 === "Redis"
     ```python
-    from types import Callable, Awaitable
+    from typing import Callable, Awaitable
     from faststream.redis import RedisMessage
     from faststream.redis.message import PubSubMessage