Teimatini Marin
02/10/2023, 4:39 PMfun main() = runBlocking {
var lastline = ""
readHugeFile().collect { value ->
val lines = (lastline+value).lines()
lines.dropLast(1).forEach {
println(it)
}
lastline = lines.last()
}
println(lastline)
}
fun readHugeFile(): Flow<String> = flowOf(
"""line 1
|line 2
|li""".trimMargin(),
"""ne 3
|line 4
|lin""".trimMargin(),
"""e 5
|line 6
""".trimMargin()
)
Alex Prince
02/10/2023, 7:02 PM.fold
instead of .collect
is probably what you're looking forTeimatini Marin
02/10/2023, 10:59 PM