C
C
Conversation with Streaming Responses
See more AI Examples
Demonstrates an AI conversation with receiving streaming responses.Chilkat C Downloads
#include <C_CkAi.h>
#include <C_CkStringBuilder.h>
void ChilkatSample(void)
{
BOOL success;
HCkAi ai;
const char *systemMsg;
const char *developerMsg;
const char *conversationName;
HCkStringBuilder sbEventName;
HCkStringBuilder sbDelta;
HCkStringBuilder 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 = CkAi_Create();
// The provider can be "openai", "google", "claude", "deepseek", "xai", or "perplexity".
// Support for additional providers will be added in future versions of Chilkat.
CkAi_putProvider(ai,"google");
// Use your provider's API key.
CkAi_putApiKey(ai,"MY_API_KEY");
// Choose a model.
CkAi_putModel(ai,"gemini-2.5-flash");
// Indicate streaming mode is to be used.
CkAi_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 = "You are a creative storyteller";
developerMsg = "";
conversationName = "test_conversation";
CkAi_NewConvo(ai,conversationName,systemMsg,developerMsg);
// Add a text input.
CkAi_InputAddText(ai,"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 = CkAi_Ask(ai,"text");
if (success == FALSE) {
printf("%s\n",CkAi_lastErrorText(ai));
CkAi_Dispose(ai);
return;
}
sbEventName = CkStringBuilder_Create();
sbDelta = CkStringBuilder_Create();
sbFullResponse = CkStringBuilder_Create();
finished = FALSE;
abortFlag = FALSE;
maxWaitMs = 5000;
while (!finished) {
result = CkAi_PollAi(ai,abortFlag);
if (result == 1) {
// We have output waiting. It should be instantly available. The maxWaitMs is just-in-case.
success = CkAi_NextAiEvent(ai,maxWaitMs,sbEventName,sbDelta);
if (success == FALSE) {
printf("%s\n",CkAi_lastErrorText(ai));
CkAi_Dispose(ai);
CkStringBuilder_Dispose(sbEventName);
CkStringBuilder_Dispose(sbDelta);
CkStringBuilder_Dispose(sbFullResponse);
return;
}
// Some AI providers send many "empty" events. Just ignore them.
if (!CkStringBuilder_ContentsEqual(sbEventName,"empty",TRUE)) {
// The delta contains the new output. This could be emitted to a display or the terminal
// as real-time output.
if (CkStringBuilder_ContentsEqual(sbEventName,"delta",TRUE)) {
// This example will emit each delta to its own line.
printf("%s\n",CkStringBuilder_getAsString(sbDelta));
// Accumulate the delta's so we can show the full response later.
CkStringBuilder_AppendSb(sbFullResponse,sbDelta);
}
else {
// A streaming AI response is always terminated by a single "null_terminator" event.
finished = CkStringBuilder_ContentsEqual(sbEventName,"null_terminator",TRUE);
}
}
}
else {
if (result == 0) {
// Nothing is immediately available. Sleep for 1/10 of a second before polling again.
CkAi_SleepMs(ai,100);
}
else {
// Something failed..
printf("%s\n",CkAi_lastErrorText(ai));
finished = TRUE;
}
}
}
// -------------------------------------------------------------
// The response is in markdown format.
// Also see Markdown to HTML Conversion Examples.
// -------------------------------------------------------------
// Show the accumulated (full) response.
printf("----\n");
printf("%s\n",CkStringBuilder_getAsString(sbFullResponse));
printf("----\n");
// ----------------------------------------------------------------------------------------------------------
// For the 2nd request in this conversation, ask for a shorter version of the story.
CkAi_InputAddText(ai,"Rewrite the story, but this time make it shorter, about one third as long.");
success = CkAi_Ask(ai,"text");
if (success == FALSE) {
printf("%s\n",CkAi_lastErrorText(ai));
CkAi_Dispose(ai);
CkStringBuilder_Dispose(sbEventName);
CkStringBuilder_Dispose(sbDelta);
CkStringBuilder_Dispose(sbFullResponse);
return;
}
CkStringBuilder_Clear(sbFullResponse);
finished = FALSE;
while (!finished) {
result = CkAi_PollAi(ai,abortFlag);
if (result == 1) {
// We have output waiting. It should be instantly available. The maxWaitMs is just-in-case.
success = CkAi_NextAiEvent(ai,maxWaitMs,sbEventName,sbDelta);
if (success == FALSE) {
printf("%s\n",CkAi_lastErrorText(ai));
CkAi_Dispose(ai);
CkStringBuilder_Dispose(sbEventName);
CkStringBuilder_Dispose(sbDelta);
CkStringBuilder_Dispose(sbFullResponse);
return;
}
// Some AI providers send many "empty" events. Just ignore them.
if (!CkStringBuilder_ContentsEqual(sbEventName,"empty",TRUE)) {
// The delta contains the new output. This could be emitted to a display or the terminal
// as real-time output.
if (CkStringBuilder_ContentsEqual(sbEventName,"delta",TRUE)) {
// This example will emit each delta to its own line.
printf("%s\n",CkStringBuilder_getAsString(sbDelta));
// Accumulate the delta's so we can show the full response later.
CkStringBuilder_AppendSb(sbFullResponse,sbDelta);
}
else {
// A streaming AI response is always terminated by a single "null_terminator" event.
finished = CkStringBuilder_ContentsEqual(sbEventName,"null_terminator",TRUE);
}
}
}
else {
if (result == 0) {
// Nothing is immediately available. Sleep for 1/10 of a second before polling again.
CkAi_SleepMs(ai,100);
}
else {
// Something failed..
printf("%s\n",CkAi_lastErrorText(ai));
finished = TRUE;
}
}
}
printf("----\n");
printf("%s\n",CkStringBuilder_getAsString(sbFullResponse));
CkAi_Dispose(ai);
CkStringBuilder_Dispose(sbEventName);
CkStringBuilder_Dispose(sbDelta);
CkStringBuilder_Dispose(sbFullResponse);
}