Not sure what I'm missing here. ```doSomething() ...

# coroutines

[Colton Idle]

Not sure what I'm missing here.

doSomething() <=== Works!
bufferedReader.forEachLine {
  doSomething() <=== Doesn't work (Error: "Suspension functions can be called only within coroutine body")
}

what about a bufferedReader.forEachLine kicks me out of my coroutine body...? hm

[Johann Pardanaud]

forEachLine is not an inline function, which is why the lambda is no longer executing in the coroutine scope

[Johann Pardanaud]

maybe this is something you should report on YouTrack, I don't know if there is any reason for this function to not be an inline one

[Colton Idle]

Interesting! I did

while (bufferedReader.readLine().also { currentLine = it } != null) {

and now everything works! Thanks

[Colton Idle]

I'll try to follow a bug on youtrack at some point. lol

[Jacob]

https://slack-chats.kotlinlang.org/t/454925/any-built-in-way-to-create-a-flow-of-lines-from-a-file-on-jv#99d2c7ed-c73d-45fe-9b7e-04e131e70866

[Jacob]

^demonstrates how to convert a buffered reader to a flow of lines which can easily be consumed with suspend functions

[araqnid]

although opening the file should be part of the flow and only executed on Dispatchers.IO when the flow is collected, not when File.lineFlow() is called

[araqnid]

so more like:

fun File.lineFlow(): Flow<String> = flow {
    bufferedReader().useLines { lines ->
        emitAll(lines.asFlow())
    }
}.flowOn(<http://Dispatchers.IO|Dispatchers.IO>)

[Sam]

Looks like this has been discussed in https://youtrack.jetbrains.com/issue/KT-17192 — forEachLine is mentioned in the comments