Sihyeon Jang 3da22af859 fix(utils/middleware): flush pending chat deltas on stream termination ...

Guarantees the last partial delta chunk is emitted when the SSE stream closes (EOF, break, or `[DONE]` sentinel).

* Buffer `last_delta_data` and track `delta_count`
* Flush automatically once `delta_count >= chunk_size`
* Perform a final flush after the iterator ends

Signed-off-by: Sihyeon Jang <sihyeon.jang@navercorp.com>

2025-08-16 13:03:57 +09:00

..

images

…

telemetry

added otel lgos specific config

2025-08-02 22:15:22 +03:00

access_control.py

…

audit.py

Fix audit get_current_user

2025-08-10 02:10:00 +02:00

auth.py

refac

2025-08-09 21:38:31 +04:00

chat.py

…

code_interpreter.py

…

embeddings.py

…

filter.py

…

logger.py

chore: format

2025-08-06 14:27:58 +04:00

middleware.py

fix(utils/middleware): flush pending chat deltas on stream termination

2025-08-16 13:03:57 +09:00

misc.py

refac/fix: reasoning_content chunk

2025-08-09 00:31:28 +04:00

models.py

…

oauth.py

refac: async webhook request

2025-08-15 00:07:02 +04:00

payload.py

feat: stream delta chunk

2025-08-09 23:43:27 +04:00

pdf_generator.py

…

plugin.py

…

redis.py

enh/refac: redis cluster support

2025-08-04 14:15:08 +04:00

response.py

fix: ollama tool call

2025-07-18 06:11:53 +08:00

security_headers.py

…

task.py

…

tools.py

feat: use AIOHTTP_CLIENT_TIMEOUT for tool calls to make timeout configurable

2025-08-12 12:29:02 +02:00

webhook.py

refac: async webhook request

2025-08-15 00:07:02 +04:00