pub struct A2AEventMapper { /* private fields */ }Expand description
Stateful mapper that tracks the latest A2A task state across a stream.
Implementations§
Source§impl A2AEventMapper
impl A2AEventMapper
pub fn new() -> Self
pub fn latest_task_id(&self) -> Option<&str>
pub fn context_id(&self) -> Option<&str>
pub fn is_terminal(&self) -> bool
pub fn final_text(&self) -> &str
Sourcepub fn map_stream_response(
&mut self,
response: StreamResponse,
) -> A2AMappedEvents
pub fn map_stream_response( &mut self, response: StreamResponse, ) -> A2AMappedEvents
Map a single A2A StreamResponse to Bamboo AgentEvents and metadata.
Trait Implementations§
Source§impl Default for A2AEventMapper
impl Default for A2AEventMapper
Source§fn default() -> A2AEventMapper
fn default() -> A2AEventMapper
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for A2AEventMapper
impl RefUnwindSafe for A2AEventMapper
impl Send for A2AEventMapper
impl Sync for A2AEventMapper
impl Unpin for A2AEventMapper
impl UnsafeUnpin for A2AEventMapper
impl UnwindSafe for A2AEventMapper
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