Add channel buffer for incoming messages.

whilo · Apr 12, 2024 · fca1d77 · fca1d77
1 parent 8628eb4
commit fca1d77
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/src/ie/simm/runtimes/openai.clj b/src/ie/simm/runtimes/openai.clj
@@ -8,8 +8,7 @@
             [taoensso.timbre :refer [debug warn]]
             [ie.simm.config :refer [config]]
             [clojure.core.async :refer [chan pub sub]]
-            [superv.async :refer [S go-try go-loop-try <? put?]]
-            [etaoin.api :as e]))
+            [superv.async :refer [S go-try go-loop-try <? put?]]))
 
 (require-python '[openai :refer [OpenAI]])
 

diff --git a/src/ie/simm/runtimes/relational_assistance.clj b/src/ie/simm/runtimes/relational_assistance.clj
@@ -235,7 +235,7 @@
         pi (pub pub-in :type)
 
        ;; subscriptions for this runtime context
-        msg-ch (chan)
+        msg-ch (chan 1000)
         _ (sub pi :ie.simm.runtimes.telegram/message msg-ch)
 
        ;; do the same in reverse for outputs from below