Expand description
Message processing for the A2A server.
MessageProcessor owns the repositories and services needed to handle an
inbound message and persist the resulting task. StreamProcessor drives
the streaming execution pipeline, reporting progress as StreamEvents
over an mpsc channel. Both the streaming and non-streaming entry points live
in the submodules.
Copyright (c) systemprompt.io — Business Source License 1.1. See https://systemprompt.io for licensing details.