Function linesToMessages

src/utils/streamCompletion.ts:27–37

* Asynchronously converts a stream of lines into messages. * @param {AsyncIterable } linesAsync - Stream of lines to convert into messages. * @returns {AsyncIterable } - An asynchronous iterable that yields parsed messages from the input lines.

(linesAsync: any)

 * @returns {AsyncIterable<any>} - An asynchronous iterable that yields parsed messages from the input lines.
 */
async function* linesToMessages(linesAsync: any) {
  for await (const line of linesAsync) {
    const message = line.substring("data :".length);
    try {
      const parsedMessage = JSON.parse(message);
      yield parsedMessage;
    } catch (error) {
      console.error("Could not JSON parse stream message", message, error);
    }
  }
}

/**
 * Asynchronously completes the stream by converting chunks to lines and then to messages.