processEvent method

void processEvent(
  1. String eventType,
  2. Map<String, dynamic> data
)

Process a raw SSE event type and JSON data payload.

Implementation

void processEvent(String eventType, Map<String, dynamic> data) {
  final type = parseStreamEventType(eventType);
  if (type == null) return;

  switch (type) {
    case StreamEventType.messageStart:
      _handleMessageStart(data);
    case StreamEventType.contentBlockStart:
      _handleContentBlockStart(data);
    case StreamEventType.contentBlockDelta:
      _handleContentBlockDelta(data);
    case StreamEventType.contentBlockStop:
      _handleContentBlockStop(data);
    case StreamEventType.messageDelta:
      _handleMessageDelta(data);
    case StreamEventType.messageStop:
      _handleMessageStop();
    case StreamEventType.ping:
      break; // Heartbeat — no action needed.
    case StreamEventType.error:
      _handleError(data);
  }
}