sse_parser 0.1.0

sse_parser: ^0.1.0 copied to clipboard

example/sse_parser_example.dart

import 'dart:async';

import 'package:sse_parser/sse_parser.dart';

/// Two ways to use the parser.
Future<void> main() async {
  // 1. Push API — feed decoded text chunks, get events via a callback.
  final parser = SseParser(
    onEvent: (event) => print('push  -> event=${event.event} data=${event.data}'),
    onComment: (comment) => print('push  -> comment "$comment"'),
  );
  parser.feed('event: greeting\n');
  parser.feed('data: hel'); // a chunk boundary mid-token is fine
  parser.feed('lo\n\n'); // blank line dispatches the event
  parser.close();

  // 2. Stream API — typical for an HTTP response body (Stream<List<int>>).
  final byteStream = Stream<List<int>>.fromIterable([
    'event: response.output_text.delta\n'.codeUnits,
    'data: {"delta":"Hi"}\n\n'.codeUnits,
    'data: [DONE]\n\n'.codeUnits,
  ]);

  await for (final SseEvent event in byteStream.parseSse()) {
    if (event.data == '[DONE]') break;
    print('stream -> event=${event.event} data=${event.data}');
  }
}