We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4d5e573 commit dc5d14cCopy full SHA for dc5d14c
src/main/kotlin/cc/unitmesh/devti/llms/custom/CustomLLMProvider.kt
@@ -86,6 +86,7 @@ class CustomLLMProvider(val project: Project) : LLMProvider {
86
}, BackpressureStrategy.BUFFER)
87
88
try {
89
+ logger.warn("Starting to stream:")
90
return callbackFlow {
91
withContext(Dispatchers.IO) {
92
sseFlowable
@@ -94,6 +95,7 @@ class CustomLLMProvider(val project: Project) : LLMProvider {
94
95
if (engineFormat.isNotEmpty()) {
96
val chunk: String = JsonPath.parse(sse!!.data)?.read(engineFormat)
97
?: throw Exception("Failed to parse chunk")
98
+ logger.warn(" $chunk")
99
trySend(chunk)
100
} else {
101
val result: ChatCompletionResult =
0 commit comments