processStreamWithAssembler function

(Stream<StreamUpdate>, StreamAssembler) processStreamWithAssembler(Stream<List<int>> byteStream)

Process an HTTP streaming response byte stream into StreamUpdates.

This is the primary entry point for consuming a streaming API response. It performs full SSE parsing, event assembly, and emits high-level updates suitable for driving UI.

The returned StreamAssembler can be used after the stream completes to retrieve the fully assembled Message via assembler.state.toMessage().

Implementation

(Stream<StreamUpdate>, StreamAssembler) processStreamWithAssembler(
  Stream<List<int>> byteStream,
) {
  final parser = SseParser();
  final assembler = StreamAssembler();

  final stream = _processStreamImpl(byteStream, parser, assembler);
  return (stream, assembler);
}