Struct App 

pub struct App<I: UiState> {
    pub(crate) agent_thread: Option<JoinHandle<()>>,
    pub(crate) ui: I,
    pub(crate) agent_notifications: UnboundedSender<Notification>,
    pub(crate) ui_notifications: UnboundedReceiver<Notification>,
}

The application state

Fields

agent_thread: Option<JoinHandle<()>>

Agent thread running concurrently

ui: I

UI state

agent_notifications: UnboundedSender<Notification>

Notifications to the agent

ui_notifications: UnboundedReceiver<Notification>

Notification to the UI

Implementations

impl<I: UiState> App<I>

pub fn new_with_history<F: FnOnce(&Agent, Arc<Mutex<ChatHistory>>) -> Result<I>>( agent: Agent, history: &[ChatMessage], ui_notifications: NotificationChannel, create_ui: F, ) -> Result<Self>

Create a new application state around agent, pre-feeding the chat log with history.

pub fn new<F: FnOnce(&Agent, Arc<Mutex<ChatHistory>>) -> Result<I>>( agent: Agent, ui_notifications: NotificationChannel, create_ui: F, ) -> Result<Self>

Create a new application state around agent.

pub async fn run(&mut self) -> Result<()>

Run the application until it finds it should exit.

Trait Implementations

impl<I: UiState> Drop for App<I>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.