pub struct EngineResponder { /* private fields */ }Expand description
Production Responder: submits through submit_pending_response
(SessionAccess is implemented directly by SessionRepository, no
AppState wrapper needed), applies any permission grants the answer
implied (mirrors handlers::agent::respond::handlers::submit), then
resumes via [ConnectResumePort] — the connect-scoped
ResumeExecutionPort implementation that spawns through the same
crate-agnostic spawn_session_execution the bridge already uses for a
fresh prompt (bridge::ConnectBridge::run_prompt), including re-running a
gated tool call that was only a placeholder while awaiting approval.
Implementations§
Source§impl EngineResponder
impl EngineResponder
pub fn new(ctx: ConnectContext) -> Self
Trait Implementations§
Source§impl Responder for EngineResponder
impl Responder for EngineResponder
fn respond_and_resume<'life0, 'life1, 'async_trait>(
&'life0 self,
session_id: &'life1 str,
answer: String,
) -> Pin<Box<dyn Future<Output = Result<RespondAndResumeOutcome, ResponderError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Auto Trait Implementations§
impl !RefUnwindSafe for EngineResponder
impl !UnwindSafe for EngineResponder
impl Freeze for EngineResponder
impl Send for EngineResponder
impl Sync for EngineResponder
impl Unpin for EngineResponder
impl UnsafeUnpin for EngineResponder
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more