Struct RunnableCompacting 

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

Runnable<Vec<Message>, Message> wrapper that compacts the input message slice through an operator-supplied Compactor when the total character count meets or exceeds threshold_chars. Below the threshold the wrapper is a no-op delegate — the inner runnable receives the original Vec<Message> unchanged.

Construct via MessageRunnableCompactionExt::with_compaction:

use entelix::{Compactor, HeadDropCompactor, MessageRunnableCompactionExt};
use std::sync::Arc;

let compactor: Arc<dyn Compactor> = Arc::new(HeadDropCompactor);
let model = my_chat_model.with_compaction(compactor, 8_192);
let agent = entelix::create_react_agent(model, tools, None)?;

Implementations

impl<R> RunnableCompacting<R>

pub const fn threshold_chars(&self) -> usize

Threshold (in character count) at and above which the wrapper invokes the Compactor. Mirrors the budget_chars semantic the compactor uses to size its output.

pub const fn inner(&self) -> &R

Borrow the wrapped runnable.

Trait Implementations

impl<R> Runnable<Vec<Message>, Message> for RunnableCompacting<R>

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

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

where 'life0: 'async_trait, 'life1: 'async_trait, RunnableCompacting<R>: 'async_trait,

Single-shot invocation.

fn batch<'life0, 'life1, 'async_trait>( &'life0 self, inputs: Vec<I>, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<O>, Error>> + Send + 'async_trait>>

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

Batch invocation. The default runs invoke sequentially over the input vector. Implementors that can parallelize (e.g. independent provider calls) override this.

fn stream<'life0, 'life1, 'async_trait>( &'life0 self, input: I, mode: StreamMode, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<StreamChunk<O>, Error>> + Send + 'life0>>, Error>> + Send + 'async_trait>>

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

Streaming invocation, shaped by mode (see StreamMode).

fn name(&self) -> Cow<'_, str>

Human-readable identifier used by tracing and debug output. Default is the Rust type name — implementors may override with a domain label (e.g. "anthropic-messages", "json-parser").