agent-context 0.1.5

Multi-backend agent context manager with three-zone memory model
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! 压缩订阅管理请求消息。
//!
//! 每条消息的 `impl Message<…> for `[`AgentContext`](super::super::actor::AgentContext) 块定义在
//! [`context::actor`](super::super::actor) 模块中。

use kameo::actor::ReplyRecipient;

use super::outbound::NotifyCompressedForReply;

/// 设置压缩结果订阅者。Reply = `()`。
///
/// 在 [`RequestCompress`](super::inbound::RequestCompress) 生成摘要后、写入 compressed 区之前，
/// 将 [`NotifyCompressedForReply`] 发送给订阅者，订阅者返回修改后的 `(摘要, 保留)` 对。
/// 后设覆盖前设（单例语义）。
pub struct RequestSubscribeCompressed<M: Send + 'static> {
    /// 压缩结果订阅者引用
    pub recipient: ReplyRecipient<NotifyCompressedForReply<M>, (Vec<M>, Vec<M>)>,
}

/// 清除压缩结果订阅者。Reply = `()`。
///
/// 清除后 [`RequestCompress`](super::inbound::RequestCompress) 将跳过订阅者处理，直接使用原始摘要。
pub struct RequestUnsubscribeCompressed;