base

Abstract base classes for bus message serialization.

class pipecat.bus.serializers.base.MessageSerializer

Bases: ABC

Serialize and deserialize BusMessage instances for network transport.

Network bus implementations use a MessageSerializer to convert messages to bytes for transmission and reconstruct them on the receiving end.

abstractmethod serialize(message: BusMessage) → bytes

Convert a bus message to bytes.

Parameters:

message – The bus message to serialize.

Returns:

The serialized bytes.

abstractmethod deserialize(data: bytes) → BusMessage | None

Reconstruct a bus message from bytes.

Parameters:

data – The serialized bytes produced by serialize().

Returns:

The reconstructed BusMessage.