Create streaming.py

streaming.py

@@ -0,0 +1,11 @@
+from langchain_core.callbacks.base import BaseCallbackHandler
+
+class StreamHandler(BaseCallbackHandler):
+
+    def __init__(self, container, initial_text=""):
+        self.container = container
+        self.text = initial_text
+
+    def on_llm_new_token(self, token: str, **kwargs):
+        self.text += token
+        self.container.markdown(self.text)