类class
agentscope.app.middlewareInboxMiddleware
class InboxMiddleware(MiddlewareBase)源码Source
agentscope/app/middleware/_inbox_middleware.py:24–136收件箱中间件，在智能体执行流程中提供横切扩展。位于 agentscope.app.middleware 包，继承自 MiddlewareBase。核心成员包括 on_reasoning。
Each entry in the inbox is a serialised
:class:~agentscope.message.HintBlock. The middleware
deserializes them, appends to the last assistant message in
agent.state.context, and yields a one-shot HintBlockEvent
for each so the front-end sees them.
构造器摘要Constructor Summary
| 构造器Constructor | 说明Description |
|---|---|
def __init__(message_bus: MessageBus, max_count: int = 100) -> None | 初始化 `InboxMiddleware` 实例。 Initialise the middleware. |
方法摘要Method Summary
| 方法Method | 说明Description |
|---|---|
async def on_reasoning(agent: Agent, input_kwargs: dict, next_handler: Callable[..., AsyncGenerator]) -> AsyncGenerator…async | 拦截并扩展推理阶段。 Drain the inbox, inject HintBlocks into context, yield events, then continue with downstream reasoning. |
构造器详情Constructor Detail
InboxMiddleware
def __init__(message_bus: MessageBus, max_count: int = 100) -> None初始化 InboxMiddleware 实例。
Initialise the middleware.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
message_bus | MessageBus | 消息总线（类型 `MessageBus`）。The application-level message bus. |
max_count默认default 100 | int | 最大数量（类型 `int`）。Maximum entries drained per reasoning step. |
源码Source
agentscope/app/middleware/_inbox_middleware.py:41–55方法详情Method Detail
on_reasoning
async def on_reasoning(agent: Agent, input_kwargs: dict, next_handler: Callable[..., AsyncGenerator]) -> AsyncGenerator[Any, None]async
拦截并扩展推理阶段。
Drain the inbox, inject HintBlocks into context, yield events, then continue with downstream reasoning.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
agent | Agent | 智能体（类型 `Agent`）。The executing agent. `agent.state.session_id` selects the inbox to drain. |
input_kwargs | dict | 输入关键字参数（类型 `dict`）。Reasoning input kwargs (contains `tool_choice`); forwarded unchanged to `next_handler`. |
next_handler | Callable[..., AsyncGenerator] | 下一个处理器（类型 `Callable[..., AsyncGenerator]`）。The downstream middleware or core reasoning logic. |
AsyncGenerator[Any, None]
以异步流的形式返回任意,None。`Any`:
源码Source
agentscope/app/middleware/_inbox_middleware.py:57–136