pub struct ClaudeStreamCollector { /* private fields */ }Expand description
Native Claude lifecycle collector. Every failed push poisons the stream; EOF never substitutes for message_stop or an unclosed content block.
Implementations§
Source§impl ClaudeStreamCollector
impl ClaudeStreamCollector
pub fn new(limits: ClaudeStreamLimits) -> Self
pub fn push(&mut self, event: StreamEvent) -> Result<(), TransformError>
pub fn finish( self, ) -> Result<Converted<GenerateContentResponseBody>, TransformError>
Auto Trait Implementations§
impl Freeze for ClaudeStreamCollector
impl RefUnwindSafe for ClaudeStreamCollector
impl Send for ClaudeStreamCollector
impl Sync for ClaudeStreamCollector
impl Unpin for ClaudeStreamCollector
impl UnsafeUnpin for ClaudeStreamCollector
impl UnwindSafe for ClaudeStreamCollector
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