test_transport_unit

Functions

unique_channel(→ str)
spin_until_idle(transport[, limit])
encode_manual_retain_request(→ bytes)
test_request_retained_replays_cached_payload()
test_request_retained_missing_channel_is_silent()
test_retain_handler_accepts_generated_request_format()
test_retain_handler_accepts_manual_interop_format()
test_reliable_subscriber_deduplicates_but_acks_every_delivery()
test_reliable_publisher_stops_retrying_after_matching_ack()
test_reliable_publisher_retries_exactly_until_max_retries(caplog)

Module Contents

test_transport_unit.unique_channel(prefix: str) → str

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

test_transport_unit.encode_manual_retain_request(channel: str) → bytes

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(caplog)