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.