Struct App 

pub struct App { /* private fields */ }

Interactive application entry point.

Implementations

impl App

pub fn new(engine: Arc<RwLock<EngineState>>, ctx: DispatchContext) -> Self

pub fn new_with_sink( engine: Arc<RwLock<EngineState>>, ctx: DispatchContext, sink: SessionSink, ) -> Self

Construct with an active session sink — prompts and dispatcher output will be persisted.

pub fn with_events(self, rx: Receiver<EngineEvent>) -> Self

Attach a broadcast receiver sourced from WsSubscriber::events(). Received events land in AppState::event_ring and — on broadcast lag — a synthetic “lagged” marker is recorded so the operator sees the drop instead of a silent pane. Takes self by value for a fluent App::new(...).with_events(rx) pattern.

pub fn state_mut(&mut self) -> &mut AppState

Mutable access for pre-launch seeding (welcome messages, retry counters, etc.).

pub async fn run(self) -> Result<AppExit, AppError>

Run the event loop until the user quits.

Returns an AppExit summary on a clean shutdown so the caller can run post-session bookkeeping (daily wrap, milestone writes) without having to poke at App’s internal state. On an error, the error is returned; the caller must assume the session did not end cleanly and skip post-session I/O.

Errors

Propagates any terminal I/O error.

Trait Implementations

impl Debug for App

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.