Struct RunnableToSummarizerAdapter 

pub struct RunnableToSummarizerAdapter<R> { /* private fields */ }

Summarizer that delegates to any Runnable<Vec<Message>, Message> — the same shape as a chat model. Prepends a configurable system instruction so the model understands the task even when the buffer itself contains only raw user/assistant turns.

Implementations

impl<R> RunnableToSummarizerAdapter<R>

where R: Runnable<Vec<Message>, Message> + 'static,

pub fn new(runnable: R) -> Self

Build a summariser using runnable and the default system instruction.

pub fn from_arc(runnable: Arc<R>) -> Self

Build a summariser using an Arc-wrapped runnable. Useful when the same model serves multiple memories or is shared with other parts of the agent.

pub fn with_system_prompt(self, prompt: impl Into<String>) -> Self

Override the system instruction. Use to inject domain-specific summary guidance (“preserve transaction IDs verbatim”; “always summarise in the user’s preferred language”).

Trait Implementations

impl<R> Summarizer for RunnableToSummarizerAdapter<R>

where R: Runnable<Vec<Message>, Message> + 'static,

fn summarize<'life0, 'life1, 'async_trait>( &'life0 self, messages: Vec<Message>, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Summarise messages into a single string. Returning Err signals a transient failure — the consolidating buffer keeps the original messages and re-attempts next call.