Tangledup-ai/lang-agent
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

state reset

Browse Source
This commit is contained in:
goulustis
2025-12-29 22:50:57 +08:00
parent 85a1c0dda2
commit 42a6f057e4
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
lang_agent/components/text_releaser.py
View File

@@ -205,6 +205,11 @@ class TextReleaser:
- When end_key is seen: skip all pending chunks and resume after end_key - When end_key is seen: skip all pending chunks and resume after end_key
- Keys can span multiple chunks, chunks are held until key is confirmed or ruled out - Keys can span multiple chunks, chunks are held until key is confirmed or ruled out
""" """
# Reset instance state for safe reuse
self._buffer.clear()
self._producer_done.clear()
self._accumulated_text = ""
producer_thread = threading.Thread(target=self._producer, args=(text_iterator,), daemon=True) producer_thread = threading.Thread(target=self._producer, args=(text_iterator,), daemon=True)
producer_thread.start() producer_thread.start()
@@ -399,6 +404,9 @@ class AsyncTextReleaser:
- start_key and end_key are never yielded - start_key and end_key are never yielded
- When end_key is seen: skip all pending chunks and resume after end_key - When end_key is seen: skip all pending chunks and resume after end_key
""" """
# Reset instance state for safe reuse
self._accumulated_text = ""
buffer: deque = deque() # stores (chunk, chunk_start_pos, chunk_end_pos) buffer: deque = deque() # stores (chunk, chunk_start_pos, chunk_end_pos)
state = ReleaseState() state = ReleaseState()
producer_done = False producer_done = False