AsyncAPIListBatchPublisher
faststream.redis.publisher.asyncapi.AsyncAPIListBatchPublisher #
AsyncAPIListBatchPublisher(*, list, reply_to, headers, broker_middlewares, middlewares, schema_, title_, description_, include_in_schema)
Bases: ListBatchPublisher
, _ListPublisherMixin
Source code in faststream/redis/publisher/usecase.py
publish async
#
publish(message=(), list=None, *, correlation_id=None, headers=None, _extra_middlewares=(), **kwargs)
Source code in faststream/redis/publisher/usecase.py
request async
#
request(message=None, list=None, *, correlation_id=None, headers=None, timeout=30.0, _extra_middlewares=())
Source code in faststream/redis/publisher/usecase.py
setup #
add_prefix #
schema #
Returns the schema of the API operation as a dictionary of channel names and channel objects.
add_middleware #
create staticmethod
#
create(*, channel, list, stream, headers, reply_to, broker_middlewares, middlewares, title_, description_, schema_, include_in_schema)
Source code in faststream/redis/publisher/asyncapi.py
get_name #
get_description #
get_schema #
Source code in faststream/redis/publisher/asyncapi.py
get_payloads #
Source code in faststream/broker/publisher/usecase.py
set_test #
Turn publisher to testing mode.