Are there any types of streaming data types that I can get from the Client that can be safely shared...

# ktor

[Sam Garfinkel]

Are there any types of streaming data types that I can get from the Client that can be safely shared and read from concurrently? I think what I’m looking for is something that will replay the already buffered content and will also properly emit to suspended functions when new content is available.

[e5l]

Hi @Sam Garfinkel, the ByteReadChannel perfectly fits the description 🙂

[e5l]

client.get<ByteReadChannel>(...)

[Sam Garfinkel]

It’s safe to call read from multiple coroutines in parallel and they will act correctly? I’m slightly skeptical only because it looks a lot like an InputStream and I wanted to make sure that the cursor is not shared.

[e5l]

It's safe to share between threads, but unsafe to read concurrently. What are you expecting from concurrent reading?

[Sam Garfinkel]

I’m mostly wondering if there’s a way to do

suspend fun foo() = coroutineScope {
    val bar = client.get<..>
    val first = async { bar.readAllButSuspendCoroutineAsNeeded() }
    val second = async { bar.readAllButSuspendCoroutineAsNeeded() }
    println("${first.await()} ${second.await()}")
}

[Sam Garfinkel]

I’d like to have multiple read operations running at once on the same streaming data source. The reason being I’m dealing with an annoyingly large response and I’m trying to optimize the processing of bar