ABCBroker
faststream.broker.core.abc.ABCBroker #
Bases: Generic[MsgType]
Source code in faststream/broker/core/abc.py
add_middleware #
Append BrokerMiddleware to the end of middlewares list.
Current middleware will be used as a most inner of already existed ones.
Source code in faststream/broker/core/abc.py
subscriber abstractmethod
#
Source code in faststream/broker/core/abc.py
publisher abstractmethod
#
Source code in faststream/broker/core/abc.py
include_router #
Includes a router in the current object.