Struct StreamTranslationEngine 

pub struct StreamTranslationEngine { /* private fields */ }

Registry-backed streaming translator.

Implementations

impl StreamTranslationEngine

pub fn new(registry: StreamCodecRegistry) -> Self

Creates a streaming engine from an explicit codec registry.

pub fn translate_event( &self, state: &mut StreamTranslationState, source: impl Into<FormatId>, target: impl Into<FormatId>, event: &Value, ) -> Result<Vec<Value>>

Translates one source provider event into target provider events.

pub fn finish( &self, state: &mut StreamTranslationState, target: impl Into<FormatId>, ) -> Result<Vec<Value>>

Finishes target-provider stream emission after the source stream closes.

pub fn translate_event_with_builtins( state: &mut StreamTranslationState, source: impl Into<FormatId>, target: impl Into<FormatId>, event: &Value, ) -> Vec<Value>

Convenience helper using built-in codecs and error events instead of Result.

Trait Implementations

impl Default for StreamTranslationEngine

fn default() -> StreamTranslationEngine

Returns the “default value” for a type.