anybody know if there's a way to get a kotlinx io `Source` from a `ByteReadChannel`?

# ktor

[edenman]

anybody know if there's a way to get a kotlinx io Source from a ByteReadChannel?

[edenman]

found https://youtrack.jetbrains.com/issue/KTOR-6487 but it was closed

[jw]

Seems impossible. You could go the other way, though.

[jw]

The only option I see would be to use runBlocking which is bad because the Source could already be inside a coroutine on an IO thread. And you're not supposed to do that.

[jw]

The API contract of RawSource.read is that it will obtain at least a single byte, and that requires blocking which an async mechanism just can't fulfill.

[edenman]

for now i'm just gonna try this

[edenman]

Untitled

Untitled

[jw]

Okio has a Pipe which is closer to what's needed here

[edenman]

this is not a pipe

[edenman]

(sorry)

[jw]

it doesn't even register as strange with me anymore. i just know your flavor of english will contain these references

[jw]

en_US-Denman

[edenman]

Locale me Maybe

[jw]

I could see kotlinx.io getting some sort of suspension-based, pipe-like type in the future so that one coroutine could be consuming a bunch of data sources (like http/2 streams) and writing them into these pipes for individual consumers to suspend and wait for chunks as segments

although not sure how you make all the nice Source APIs work such that when there's a byte underflow they suspend. seems like maybe you'd be able to require so many bytes in a Buffer or something and then you get to non-blocking read from that until you decide to wait or hit EOF and have to wait

[edenman]

mmm yeah

[Aleksei Tirman [JB]]

You can follow this feature request.