parseJsonlStream function

Stream<String> parseJsonlStream(
  1. Stream<List<int>> byteStream
)

Parses a byte stream of newline-delimited JSON (JSONL/NDJSON) into individual JSON strings, one per non-empty line.

Implementation

Stream<String> parseJsonlStream(Stream<List<int>> byteStream) {
  return byteStream
      .transform(const Utf8Decoder(allowMalformed: true))
      .transform(const LineSplitter())
      .where((line) => line.trim().isNotEmpty);
}