Struct StreamAssembler 

pub struct StreamAssembler { /* private fields */ }

Assembles streaming events into complete content blocks.

Feed it StreamEventPayload values via process and collect the resulting AssembledEvents.

Example

let mut assembler = StreamAssembler::new();
// ... for each stream event payload:
// let events = assembler.process(&payload);
// for event in events { /* handle */ }

Implementations

impl StreamAssembler

pub fn new() -> Self

Create a new assembler with no state.

pub fn reset(&mut self)

Reset all internal state (e.g. between messages).

pub fn process(&mut self, event: &StreamEventPayload) -> Vec<AssembledEvent>

Process a single streaming event and return zero or more assembled events.

Trait Implementations

impl Debug for StreamAssembler

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

Formats the value using the given formatter.

impl Default for StreamAssembler

fn default() -> StreamAssembler

Returns the “default value” for a type.