Skip to main content

frame_stream_message

Function frame_stream_message 

Source
pub fn frame_stream_message(
    from: &str,
    values: &[RuntimeValue],
) -> Result<Vec<u8>, String>
Expand description

Frame a sequence of values as one batch STREAM message: [magic][sender][framed value-message]*, each value length-delimited (via crate::concurrency::stream::frame_for_stream) so the receiver deframes them incrementally and reads each in place. ONE relay publish ships the whole batch — Kafka-style streaming that amortizes per-message overhead — and Await stream reassembles the list. Each value is encoded self-describingly so it round-trips without the type registry.