Expand description
Lazy in-memory stream combinators for STREAM 6.
This crate composes stream-core packet spines without talking to devices, files, or transports. Later Lisp and remote surfaces can lower graph forms into these Rust-level combinators.
Structs§
- Cell
Snapshot - Immutable snapshot of a
StreamCellvalue at a known version. - Clock
Converted Stream - A clock-converted stream paired with the diagnostics its conversion emits.
- Stream
- Cloneable handle to a lazy combinator stream.
- Stream
Cell - Versioned, thread-safe cell holding the latest value of a stream.
- Stream
Recording - A fully captured stream: its metadata plus every packet it produced.
Enums§
- Seek
Target - Where a
seekshould begin replaying within a recorded stream.
Traits§
- Stream
Node - Lazy source of stream packets backing a
Stream.
Functions§
- clock_
convert - Rewrites each packet’s ticks via
convert, collecting its diagnostics. - event_
join_ data_ kind - Returns the canonical data-packet kind produced by event joins.
- event_
rate_ gate - Bridges an event stream into the control clock domain as a rate gate.
- expr_
path - Resolves a dotted
pathof symbol keys through nested map expressions. - fan
- Splits
sourceinto aFanoutof two readers that each see all packets. - filter
- Returns a stream keeping only packets for which
predholds. - filter_
data_ field_ eq - Keeps data packets whose payload field at
pathequalsexpected. - filter_
data_ kind - Returns a stream keeping only data packets whose kind equals
kind. - filter_
data_ kind_ stage - Returns a reusable stage form of
filter_data_kind. - filter_
data_ shape - Returns a stream keeping only data packets whose payload matches
matches. - filter_
data_ shape_ stage - Returns a reusable stage form of
filter_data_shape. - filter_
stage - Returns a reusable stage form of
filter. - identity
- Returns a stage that forwards its source stream unchanged.
- jitter_
buffer - Reorders packets by
clocktick, tolerating up tomax_late_packets. - join_
data_ on_ field - Inner-joins two data streams on equal field values.
- latency_
comp_ delay - Records a
frames-frame latency-compensation delay over the stream. - map
- Returns a stream that applies
fto every packet ofsource. - map_
data_ expr - Returns a stream that rewrites each data packet’s payload expression with
f. - map_
data_ expr_ stage - Returns a reusable stage form of
map_data_expr. - map_
stage - Returns a reusable stage form of
map. - merge
- Returns a stream interleaving
leftandrightin pull arrival order. - merge_
by_ clock - Returns a stream merging
leftandrightordered by theirclocktick. - model_
event_ data_ kind - Returns the canonical data-packet kind for model events.
- pipe
- Applies a sequence of
StreamStagetransforms left-to-right tosource. - project_
data_ field - Projects each data payload down to the sub-expression at
path. - rank_
data_ by_ i64_ field - Reorders recorded data packets by an
i64score read frompath. - rank_
frontier_ data_ kind - Returns the canonical data-packet kind for rank-frontier updates.
- record_
bang - Drains
sourcetodoneand captures it as aStreamRecording. - record_
cassette_ bang - Records
sourceto completion and serializes it to a cassette forprofile. - record_
events - Reconstructs a recording from an arbitrary sequence of kernel
events. - record_
ledger_ run - Reconstructs a recording from all of
run’s events inledger. - record_
ledger_ slice - Reconstructs a recording from the events of
runwithinseq_range. - redact_
data_ field - Replaces each data payload’s value at
pathwithredaction. - replay
- Returns a fresh stream replaying every packet of
recording. - replay_
cassette - Rebuilds a replayable stream from a serialized transport
cassette. - resample_
pcm - Resamples a PCM stream from
input_hztooutput_hz. - run_
bang - Drains
streaminto kernel events forrun, starting atstart_seq. - seek
- Returns a stream that skips ahead in
sourceto the first packet attarget. - stream_
cell - Builds a
StreamCellholdingvalueat version0. - stream_
window_ data_ kind - Returns the canonical data-packet kind emitted by
window_by_count. - take
- Returns a stream that yields at most the first
limitpackets ofsource. - take_
stage - Returns a reusable stage form of
take. - tap
- Returns a stream that runs
fon each packet as a side effect, unchanged. - tap_
diagnostics - Returns a stream that runs
fon each diagnostic packet, leaving it intact. - tap_
diagnostics_ stage - Returns a reusable stage form of
tap_diagnostics. - tap_
stage - Returns a reusable stage form of
tap. - window_
by_ count - Returns a stream that batches packets into windows of
countpackets each. - window_
by_ count_ stage - Returns a reusable stage form of
window_by_count.
Type Aliases§
- Stream
Stage - A reusable, composable transformation from one
Streamto another.