From fca1d778dd19bf8d63ea3e026b7ec306b5988165 Mon Sep 17 00:00:00 2001
From: Christian Weilbach <ch_weil@topiq.es>
Date: Fri, 12 Apr 2024 04:08:19 +0000
Subject: [PATCH] Add channel buffer for incoming messages.

---
 src/ie/simm/runtimes/openai.clj                | 3 +--
 src/ie/simm/runtimes/relational_assistance.clj | 2 +-
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/src/ie/simm/runtimes/openai.clj b/src/ie/simm/runtimes/openai.clj
index cbcef15..5559fed 100644
--- 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
index 5a4bf2d..c14ae03 100644
--- 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