angee.messaging._wire

Console-safe coercions shared by messaging vendor wire adapters.

text

def text(value: object) -> str

Return one wire scalar as stripped text.

mapping

def mapping(value: object) -> Mapping[str, Any] | None

Return value when it is a mapping.

sequence

def sequence(value: object) -> Sequence[Any]

Return a non-text wire sequence, or an empty tuple.

millis_to_utc

def millis_to_utc(value: object) -> datetime | None

Convert a positive millisecond epoch to an aware UTC instant.