pub struct StreamConverter { /* private fields */ }Expand description
Stateful 0..N stream-event converter for one resolved pair.
Create one converter per upstream response and retain it until
finish. This preserves pair-specific state such as tool
call arguments split across multiple frames.
Implementations§
Source§impl StreamConverter
impl StreamConverter
pub fn new( pair: TransformPair, ctx: TransformContext, ) -> Result<Self, TransformError>
Sourcepub fn push(
&mut self,
data: &str,
) -> Result<Vec<StreamEventOut>, TransformError>
pub fn push( &mut self, data: &str, ) -> Result<Vec<StreamEventOut>, TransformError>
Convert one decoded upstream event into zero or more inbound events.
Sourcepub fn push_detailed(
&mut self,
data: &str,
) -> Result<TransformOutput<Vec<StreamEventOut>>, TransformError>
pub fn push_detailed( &mut self, data: &str, ) -> Result<TransformOutput<Vec<StreamEventOut>>, TransformError>
Convert one event and return semantic-loss diagnostics produced by it.
Sourcepub fn finish(&mut self) -> Result<Vec<StreamEventOut>, TransformError>
pub fn finish(&mut self) -> Result<Vec<StreamEventOut>, TransformError>
Flush pair-specific state into zero or more final inbound events.
Sourcepub fn finish_detailed(
&mut self,
) -> Result<TransformOutput<Vec<StreamEventOut>>, TransformError>
pub fn finish_detailed( &mut self, ) -> Result<TransformOutput<Vec<StreamEventOut>>, TransformError>
Flush state and return any final semantic-loss diagnostics.
Auto Trait Implementations§
impl Freeze for StreamConverter
impl RefUnwindSafe for StreamConverter
impl Send for StreamConverter
impl Sync for StreamConverter
impl Unpin for StreamConverter
impl UnsafeUnpin for StreamConverter
impl UnwindSafe for StreamConverter
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more