core/com.river.core/lines

lines

Splits and buffers the Flow of String into lines, emitting each line as a separate element in the resulting Flow.

This function buffers incoming strings until it encounters a line break (\n). It then emits each line as a separate string. If the incoming strings do not contain any line breaks, they are buffered until a line break is encountered or the flow is completed.

Return

A new Flow where each element represents a line from the original Flow of String.

Example usage:

val flow = flowOf(
   "Hel",
   "lo,",
   " world!",
   "\nW",
   "elcome to River!"
)

flow
    .lines()
    .collect(::println) //"Hello, world!", "Welcome to River!"