Trait SerializedSource 

pub trait SerializedSource: Send + Sync {
    // Required method
    fn subscribe(&self) -> Box<dyn SerializedReader>;

    // Provided method
    fn serializer_scratch_capacity(&self) -> Option<usize> { ... }
}

A record’s outbound wire interface, built where the record type T is known (OutboundConnectorBuilder::finish) and consumed by the pumps as bytes. Replaces the erased ConsumerTrait + serializer + topic-provider triple.

Required Methods

fn subscribe(&self) -> Box<dyn SerializedReader>

Subscribe to the record’s updates.

Synchronous and infallible — the buffer handle is pre-resolved at construction.

Provided Methods

fn serializer_scratch_capacity(&self) -> Option<usize>

Scratch capacity requested by this source’s into-slice serializer.

None means the source only supports the existing owned serializer. A source whose reader can return SerializedPayload::Scratch must return Some(capacity) here so the route pump provides that storage.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors