Close #4. chat_append() now waits for flush before sending message st…

…ream
posit-dev · Oct 10, 2024 · a8d8b23 · a8d8b23
1 parent d58fd39
commit a8d8b23
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/R/chat.R b/R/chat.R
@@ -76,7 +76,10 @@ chat_append <- function(id, response, session = getDefaultReactiveDomain()) {
     # Already a generator (sync or async)
     stream <- response
   }
-  chat_append_stream(id, stream, session = session)
+  do_stream <- function() {
+    chat_append_stream(id, stream, session = session)
+  }
+  session$onFlushed(do_stream)
 }
 
 #' Low-level function to append a message to a chat control