fix(streaming): correct accumulation of output tokens (#361)

anthropics · Mar 29, 2024 · 6e78091 · 6e78091
1 parent 2a79781
commit 6e78091
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/lib/MessageStream.ts b/src/lib/MessageStream.ts
@@ -450,6 +450,7 @@ export class MessageStream implements AsyncIterable<MessageStreamEvent> {
       case 'message_delta':
         snapshot.stop_reason = event.delta.stop_reason;
         snapshot.stop_sequence = event.delta.stop_sequence;
+        snapshot.usage.output_tokens = event.usage.output_tokens;
         return snapshot;
       case 'content_block_start':
         snapshot.content.push(event.content_block);