To use ChatStreaming, call it as go routine and then listen to the channel until it's closed Example of ChatStreaming usage : Chat := NewOpenAIChatModel(token,"",modelname) streamingChannel := make(chan model.ChatMessage,100) // make it buffered go Chat.ChatStreaming(ctx,messages, model.WithIsStreaming(true), model.WithStreamingChannel(streamingChannel)) for { value, ok := <-streamingChannel if ok && !model.IsStreamFinished(value) { fmt.Print(value.Content) } else { fmt.Println("") break } } */.

IsStreamFinished check if it's the end of message.

ChatModelMock is a mock implementation of ChatModel.

LLMModelMock is a mock implementation of LLMModel.

go:generate moq -out model_chat_moq.go .

go:generate moq -out model_moq.go .