test_transport_unit
===================

.. py:module:: test_transport_unit


Functions
---------

.. autoapisummary::

   test_transport_unit.unique_channel
   test_transport_unit.spin_until_idle
   test_transport_unit.encode_manual_retain_request
   test_transport_unit.test_request_retained_replays_cached_payload
   test_transport_unit.test_request_retained_missing_channel_is_silent
   test_transport_unit.test_retain_handler_accepts_generated_request_format
   test_transport_unit.test_retain_handler_accepts_manual_interop_format
   test_transport_unit.test_reliable_subscriber_deduplicates_but_acks_every_delivery
   test_transport_unit.test_reliable_publisher_stops_retrying_after_matching_ack
   test_transport_unit.test_reliable_publisher_retries_exactly_until_max_retries


Module Contents
---------------

.. py:function:: unique_channel(prefix: str) -> str

.. py:function:: spin_until_idle(transport: raccoon_transport.Transport, limit: int = 64)

.. py:function:: encode_manual_retain_request(channel: str) -> bytes

.. py:function:: test_request_retained_replays_cached_payload()

.. py:function:: test_request_retained_missing_channel_is_silent()

.. py:function:: test_retain_handler_accepts_generated_request_format()

.. py:function:: test_retain_handler_accepts_manual_interop_format()

.. py:function:: test_reliable_subscriber_deduplicates_but_acks_every_delivery()

.. py:function:: test_reliable_publisher_stops_retrying_after_matching_ack()

.. py:function:: test_reliable_publisher_retries_exactly_until_max_retries(caplog)