Struct StreamCassette 

pub struct StreamCassette { /* private fields */ }

A recorded, replayable trace of a single stream.

Holds the stream metadata, the ordered envelopes, derived timing, the deduplicated diagnostic symbols observed, and the final StreamStats. A cassette can be rebuilt into a live StreamValue via replay_stream_value, serialized to an Expr map, and validated as a golden fixture.

Implementations

impl StreamCassette

pub fn from_stream_value( stream: &StreamValue, profile: TransportProfile, ) -> Result<Self>

Records a cassette by draining every packet from a live stream.

Pulls packets until the stream is exhausted, snapshots its final stats, and builds the cassette from the metadata, drained items, and the given TransportProfile.

pub fn from_items( metadata: StreamMetadata, items: Vec<StreamItem>, profile: TransportProfile, final_stats: StreamStats, ) -> Result<Self>

Records a cassette from already-drained stream items.

Wraps each item in a sequenced StreamEnvelope under the given TransportProfile, then delegates to from_envelopes.

pub fn from_envelopes( metadata: StreamMetadata, envelopes: Vec<StreamEnvelope>, final_stats: StreamStats, ) -> Result<Self>

Builds a cassette directly from sequenced envelopes.

Derives the timing and the deduplicated diagnostic set from the envelopes, pairing them with the supplied metadata and final stats.

pub fn metadata(&self) -> &StreamMetadata

Returns the metadata of the recorded stream.

pub fn envelopes(&self) -> &[StreamEnvelope]

Returns the recorded envelopes in sequence order.

pub fn timing(&self) -> &StreamCassetteTiming

Returns the derived timing summary for the trace.

pub fn diagnostics(&self) -> &[Symbol]

Returns the deduplicated diagnostic symbols observed during recording.

pub fn final_stats(&self) -> &StreamStats

Returns the final accumulated stats captured at end of trace.

pub fn items(&self) -> Result<Vec<StreamItem>>

Reconstructs the stream items from the recorded envelopes.

Each item pairs an envelope’s packet with its captured ticks, ready to feed a replay stream.

pub fn replay_stream_value(&self) -> Result<StreamValue>

Rebuilds a live, pull-based StreamValue from the recorded trace.

pub fn to_expr(&self) -> Expr

Serializes the cassette to an Expr map keyed by field symbol.

The map carries the format symbol, metadata table, timing, envelope list, diagnostics, and final stats, suitable for persistence and round-tripping through from_expr.

pub fn from_expr(expr: &Expr) -> Result<Self>

Deserializes a cassette from an Expr map produced by to_expr.

Validates the field set and format symbol, then reconstructs metadata, envelopes, timing, diagnostics, and final stats. Fails closed on an unknown format, missing or unexpected fields, or type mismatches.

pub fn redacted(&self) -> Result<Self>

Returns a copy with host-device names and private payloads redacted.

Redacts the metadata, every envelope, and the diagnostic symbols so the result is safe to persist as a golden fixture.

pub fn validate_golden_fixture( &self, path: &str, ) -> Result<StreamGoldenFixtureReport>

Validates the cassette as a golden fixture at path.

Checks the path lives under STREAM_CASSETTE_FIXTURE_ROOT with the cassette extension, that the trace is finite, that envelope sequences match their packet index, that each transport profile is replayable or previewable but never realtime, and that no unredacted payload or host-device name remains. Returns a StreamGoldenFixtureReport on success, or an error describing the first failed invariant.

Trait Implementations

impl Clone for StreamCassette

fn clone(&self) -> StreamCassette

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamCassette

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for StreamCassette

impl PartialEq for StreamCassette

fn eq(&self, other: &StreamCassette) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for StreamCassette