wip

crates/assistant2/src/active_thread.rs

@@ -223,7 +223,10 @@ impl ActiveThread {
         cx: &mut Context<Self>,
     ) -> Self {
         let subscriptions = vec![
-            cx.observe(&thread, |_, _, cx| cx.notify()),
+            cx.observe(&thread, |_, _, cx| {
+                println!("Thread notified!");
+                cx.notify()
+            }),
             cx.subscribe_in(&thread, window, Self::handle_thread_event),
         ];
 
@@ -371,7 +374,7 @@ impl ActiveThread {
         window: &mut Window,
         cx: &mut Context<Self>,
     ) {
-        match event {
+        match dbg!(event) {
             ThreadEvent::ShowError(error) => {
                 self.last_error = Some(error.clone());
             }

crates/assistant2/src/assistant_panel.rs

@@ -272,6 +272,13 @@ impl AssistantPanel {
                 cx,
             )
         });
+
+        cx.observe(&thread, |_, _, cx| {
+            println!("Panel: Thread notified!");
+            cx.notify();
+        })
+        .detach();
+
         self.message_editor = cx.new(|cx| {
             MessageEditor::new(
                 self.fs.clone(),

crates/assistant2/src/thread.rs

@@ -541,6 +541,7 @@ impl Thread {
         self.messages.push(Message { id, role, segments });
         self.touch_updated_at();
         cx.emit(ThreadEvent::MessageAdded(id));
+        cx.notify();
         id
     }