chunkStringStream method

Stream<IChunk> chunkStringStream(
  1. Stream<String> str
)

Implementation

Stream<IChunk> chunkStringStream(Stream<String> str) => str
    .map((v) => "$v\n")
    .transform(TXPieceSplitter(min(maxChunkSize, maxPostOverlap)))
    .transform(TXChunkMerger(maxSize: maxChunkSize, maxPost: maxPostOverlap));