@@ -567,7 +567,7 @@ loop:
567567 }
568568 // Reset the timeout timer since we received a chunk
569569 timer.Reset(streamChunkTimeout)
570−
570+
571571 if processErr := a.processEvent(ctx, sessionID, &assistantMsg, event); processErr != nil {
572572 if errors.Is(processErr, context.Canceled) {
573573 a.finishMessage(context.Background(), &assistantMsg, message.FinishReasonCanceled, "Request cancelled", "")