Skip to main content

event_buffer_to_stream

Function event_buffer_to_stream 

Source
pub fn event_buffer_to_stream(
    cx: &mut Cx,
    metadata: StreamMetadata,
    events: impl IntoIterator<Item = Event>,
) -> Result<StreamValue>
Expand description

Folds a buffer of run events into a pull-based StreamValue.

Chunk events become stream items, diagnostic events become diagnostic packets, and a failure or Done event ends the stream. Non-stream event kinds (started, claim, trace, effect, capture, card, final) are ignored.