Middleware lifecycle

[a14n]

Hello,

Playing with middlewares I didn't expect that a new middleware was initialized for every incoming message. How can I create a middleware that need to collect data (have a state) among several messages ? For instance a middleware that count the total of incoming messages.

[Lancetnik]

@a14n you can use our builtin middlewares as a reference - https://github.com/ag2ai/faststream/blob/main/faststream/prometheus/middleware.py

[a14n]

My confusion comes from the msg parameter on BaseMiddleware. What's its purpose given that msg is also provided when consume_scope is called.