BaseMiddleware
faststream.broker.middlewares.BaseMiddleware #
A base middleware class.
Source code in faststream/broker/middlewares/base.py
on_receive async
#
after_processed async
#
Asynchronously called after processing.
Source code in faststream/broker/middlewares/base.py
on_consume async
#
after_consume async
#
A function to handle the result of consuming a resource asynchronously.
consume_scope async
#
Asynchronously consumes a message and returns an asynchronous iterator of decoded messages.
Source code in faststream/broker/middlewares/base.py
on_publish async
#
after_publish async
#
publish_scope async
#
Publish a message and return an async iterator.