jsonlFlow.kt

import import kotlinx.io.Source
import kotlinx.io.readLine
import kotlinx.serialization.json.Json

private inline fun <reified T> jsonlFlowOf(json: Json, source: Source): Flow<T> {
    return flow {
        val line = source.readLine() ?: return@flow
        emit(json.decodeFromString(line))
    }
}