pub struct Appender<T: Clone + Send + Sync + Serialize + DeserializeOwned + 'static> { /* private fields */ }Expand description
Appender — collects values into a Vec. Multiple updates per step allowed. Used for messages, tool calls, build results, etc.
Implementations§
Trait Implementations§
Source§impl<T: Clone + Send + Sync + Serialize + DeserializeOwned + 'static> Channel for Appender<T>
impl<T: Clone + Send + Sync + Serialize + DeserializeOwned + 'static> Channel for Appender<T>
Source§fn merge(&mut self, update: Box<dyn Any + Send>)
fn merge(&mut self, update: Box<dyn Any + Send>)
Merge a boxed update value into this channel.
Source§fn clone_box(&self) -> Box<dyn Channel>
fn clone_box(&self) -> Box<dyn Channel>
Clone the channel (for snapshot isolation during parallel execution).
Source§fn checkpoint(&self) -> Result<Vec<u8>, PeError>
fn checkpoint(&self) -> Result<Vec<u8>, PeError>
Serialize channel state for checkpointing. Read more
Source§fn as_any_mut(&mut self) -> &mut dyn Any
fn as_any_mut(&mut self) -> &mut dyn Any
Downcast support — returns self as
&mut dyn Any.Source§fn is_ephemeral(&self) -> bool
fn is_ephemeral(&self) -> bool
Whether this channel should be cleared between supersteps. Read more
Source§impl<T: Clone + Clone + Send + Sync + Serialize + DeserializeOwned + 'static> Clone for Appender<T>
impl<T: Clone + Clone + Send + Sync + Serialize + DeserializeOwned + 'static> Clone for Appender<T>
Auto Trait Implementations§
impl<T> Freeze for Appender<T>
impl<T> RefUnwindSafe for Appender<T>where
T: RefUnwindSafe,
impl<T> Send for Appender<T>
impl<T> Sync for Appender<T>
impl<T> Unpin for Appender<T>where
T: Unpin,
impl<T> UnsafeUnpin for Appender<T>
impl<T> UnwindSafe for Appender<T>where
T: UnwindSafe,
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