Feature/streaming callbacks

[demoncoder-crypto]

Feature Request: Add Streaming Callbacks Utility

Currently, developers need to manually manage the response streaming process with custom code like:

const response = await model.generateContentStream([prompt]);

let textBuf = '';

while (true) {
  const { done, value } = await response.stream.next()
  if (done) {
    
    await onEnd(textBuf);
    return
  }

  if (value) {
    const currentText = value.text()
    
    onData(value.text())
    textBuf += currentText
  }
}

1. Process each chunk of text as it arrives (via onData callback)
2. Perform actions when streaming completes (via onEnd callback)

Solution

The implementation includes two main utility functions:

1. getStreamedResponse() - regular content generation
2. getStreamedChatResponse() - chat specific streaming

Example Usage

await getStreamedResponse({
  prompt: "Your prompt here",
  model: model,
  onData: (chunkText) => {
    
    console.log(chunkText);
    
  },
  onEnd: async (fullText) => {
    
    await saveToDatabase(fullText);
    
});


await getStreamedChatResponse({
  message: [{ text: "Your message here" }],
  chatSession: chat,
  onData: (chunkText) => {
    
  },
  onEnd: async (fullText) => {
    
  }
});

[google-cla]

Thanks for your pull request! It looks like this may be your first contribution to a Google open source project. Before we can look at your pull request, you'll need to sign a Contributor License Agreement (CLA).

View this failed invocation of the CLA check for more information.

For the most up to date status, view the checks section at the bottom of the pull request.

[demoncoder-crypto]

@IvanLH Please look thanks