diff --git a/internal/client/openai-compatibility_client.go b/internal/client/openai-compatibility_client.go index dec34888..0e9a08b4 100644 --- a/internal/client/openai-compatibility_client.go +++ b/internal/client/openai-compatibility_client.go @@ -346,30 +346,6 @@ func (c *OpenAICompatibilityClient) SendRawMessageStream(ctx context.Context, mo c.AddAPIResponseData(ctx, line) dataChan <- []byte(lines[i]) } - } else if bytes.HasPrefix(line, dataUglyTag) { - if bytes.Equal(line, doneTag) { - break - } - lines := translator.Response(handlerType, c.Type(), newCtx, modelName, line[5:], ¶m) - for i := 0; i < len(lines); i++ { - dataChan <- []byte(lines[i]) - } - } else if bytes.HasPrefix(line, dataUglyTag) { - if bytes.Equal(line, doneTag) { - break - } - lines := translator.Response(handlerType, c.Type(), newCtx, modelName, line[5:], ¶m) - for i := 0; i < len(lines); i++ { - dataChan <- []byte(lines[i]) - } - } else if bytes.HasPrefix(line, dataUglyTag) { - if bytes.Equal(line, doneTag) { - break - } - lines := translator.Response(handlerType, c.Type(), newCtx, modelName, line[5:], ¶m) - for i := 0; i < len(lines); i++ { - dataChan <- []byte(lines[i]) - } } } } else {