Unicode C
Unicode C
Conversation with Streaming Responses
See more AI Examples
Demonstrates an AI conversation with receiving streaming responses.Chilkat Unicode C Downloads
#include <C_CkAiW.h>
#include <C_CkStringBuilderW.h>
void ChilkatSample(void)
{
BOOL success;
HCkAiW ai;
const wchar_t *systemMsg;
const wchar_t *developerMsg;
const wchar_t *conversationName;
HCkStringBuilderW sbEventName;
HCkStringBuilderW sbDelta;
HCkStringBuilderW sbFullResponse;
BOOL finished;
BOOL abortFlag;
int maxWaitMs;
int result;
int result;
success = FALSE;
// This example assumes the Chilkat API to have been previously unlocked.
// See Global Unlock Sample for sample code.
ai = CkAiW_Create();
// The provider can be "openai", "google", "claude", "deepseek", "xai", or "perplexity".
// Support for additional providers will be added in future versions of Chilkat.
CkAiW_putProvider(ai,L"google");
// Use your provider's API key.
CkAiW_putApiKey(ai,L"MY_API_KEY");
// Choose a model.
CkAiW_putModel(ai,L"gemini-2.5-flash");
// Indicate streaming mode is to be used.
CkAiW_putStreaming(ai,TRUE);
// Create a new conversation to be maintained locally in memory.
// If the conversation is the first to be created, it is also automatically selected.
systemMsg = L"You are a creative storyteller";
developerMsg = L"";
conversationName = L"test_conversation";
CkAiW_NewConvo(ai,conversationName,systemMsg,developerMsg);
// Add a text input.
CkAiW_InputAddText(ai,L"Write a detailed story about a turtle who decides to run a bakery. Describe the setting, the kinds of pastries, how the turtle feels, and include at least three paragraphs.");
// Ask the AI for text output.
success = CkAiW_Ask(ai,L"text");
if (success == FALSE) {
wprintf(L"%s\n",CkAiW_lastErrorText(ai));
CkAiW_Dispose(ai);
return;
}
sbEventName = CkStringBuilderW_Create();
sbDelta = CkStringBuilderW_Create();
sbFullResponse = CkStringBuilderW_Create();
finished = FALSE;
abortFlag = FALSE;
maxWaitMs = 5000;
while (!finished) {
result = CkAiW_PollAi(ai,abortFlag);
if (result == 1) {
// We have output waiting. It should be instantly available. The maxWaitMs is just-in-case.
success = CkAiW_NextAiEvent(ai,maxWaitMs,sbEventName,sbDelta);
if (success == FALSE) {
wprintf(L"%s\n",CkAiW_lastErrorText(ai));
CkAiW_Dispose(ai);
CkStringBuilderW_Dispose(sbEventName);
CkStringBuilderW_Dispose(sbDelta);
CkStringBuilderW_Dispose(sbFullResponse);
return;
}
// Some AI providers send many "empty" events. Just ignore them.
if (!CkStringBuilderW_ContentsEqual(sbEventName,L"empty",TRUE)) {
// The delta contains the new output. This could be emitted to a display or the terminal
// as real-time output.
if (CkStringBuilderW_ContentsEqual(sbEventName,L"delta",TRUE)) {
// This example will emit each delta to its own line.
wprintf(L"%s\n",CkStringBuilderW_getAsString(sbDelta));
// Accumulate the delta's so we can show the full response later.
CkStringBuilderW_AppendSb(sbFullResponse,sbDelta);
}
else {
// A streaming AI response is always terminated by a single "null_terminator" event.
finished = CkStringBuilderW_ContentsEqual(sbEventName,L"null_terminator",TRUE);
}
}
}
else {
if (result == 0) {
// Nothing is immediately available. Sleep for 1/10 of a second before polling again.
CkAiW_SleepMs(ai,100);
}
else {
// Something failed..
wprintf(L"%s\n",CkAiW_lastErrorText(ai));
finished = TRUE;
}
}
}
// -------------------------------------------------------------
// The response is in markdown format.
// Also see Markdown to HTML Conversion Examples.
// -------------------------------------------------------------
// Show the accumulated (full) response.
wprintf(L"----\n");
wprintf(L"%s\n",CkStringBuilderW_getAsString(sbFullResponse));
wprintf(L"----\n");
// ----------------------------------------------------------------------------------------------------------
// For the 2nd request in this conversation, ask for a shorter version of the story.
CkAiW_InputAddText(ai,L"Rewrite the story, but this time make it shorter, about one third as long.");
success = CkAiW_Ask(ai,L"text");
if (success == FALSE) {
wprintf(L"%s\n",CkAiW_lastErrorText(ai));
CkAiW_Dispose(ai);
CkStringBuilderW_Dispose(sbEventName);
CkStringBuilderW_Dispose(sbDelta);
CkStringBuilderW_Dispose(sbFullResponse);
return;
}
CkStringBuilderW_Clear(sbFullResponse);
finished = FALSE;
while (!finished) {
result = CkAiW_PollAi(ai,abortFlag);
if (result == 1) {
// We have output waiting. It should be instantly available. The maxWaitMs is just-in-case.
success = CkAiW_NextAiEvent(ai,maxWaitMs,sbEventName,sbDelta);
if (success == FALSE) {
wprintf(L"%s\n",CkAiW_lastErrorText(ai));
CkAiW_Dispose(ai);
CkStringBuilderW_Dispose(sbEventName);
CkStringBuilderW_Dispose(sbDelta);
CkStringBuilderW_Dispose(sbFullResponse);
return;
}
// Some AI providers send many "empty" events. Just ignore them.
if (!CkStringBuilderW_ContentsEqual(sbEventName,L"empty",TRUE)) {
// The delta contains the new output. This could be emitted to a display or the terminal
// as real-time output.
if (CkStringBuilderW_ContentsEqual(sbEventName,L"delta",TRUE)) {
// This example will emit each delta to its own line.
wprintf(L"%s\n",CkStringBuilderW_getAsString(sbDelta));
// Accumulate the delta's so we can show the full response later.
CkStringBuilderW_AppendSb(sbFullResponse,sbDelta);
}
else {
// A streaming AI response is always terminated by a single "null_terminator" event.
finished = CkStringBuilderW_ContentsEqual(sbEventName,L"null_terminator",TRUE);
}
}
}
else {
if (result == 0) {
// Nothing is immediately available. Sleep for 1/10 of a second before polling again.
CkAiW_SleepMs(ai,100);
}
else {
// Something failed..
wprintf(L"%s\n",CkAiW_lastErrorText(ai));
finished = TRUE;
}
}
}
wprintf(L"----\n");
wprintf(L"%s\n",CkStringBuilderW_getAsString(sbFullResponse));
CkAiW_Dispose(ai);
CkStringBuilderW_Dispose(sbEventName);
CkStringBuilderW_Dispose(sbDelta);
CkStringBuilderW_Dispose(sbFullResponse);
}