Slightly different question from yesterday. I have a flow that can only be consumed once(a grpc stre...

# coroutines

[taer]

Slightly different question from yesterday. I have a flow that can only be consumed once(a grpc stream). I need to pull the first element off like with first but I don't want to close the flow. I need the rest of the elements to be still available.

[Tijl]

https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/with-index.html

[taer]

Something more like this

val requests: Flow<Request>

val foo = requests.toList()
val targetServer = doSomethingWithFirstElement(foo.first())
targetServer.makeReuqest(foo.asFlow())

[taer]

but without pulling the flow into memory

[Tijl]

you can do shareIn https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/share-in.html

then collect the SharedFlow once with first, and another time with a filter to omit the first item.

[taer]

I tried that. The shareIn got greedy and drained the flow. my second call the flow only contained the last element. I had set it up w/ a replay of one.

[taer]

putting some logging around it to see what's going on. I kinda want that buffer(0) behavior with one replay

[Tijl]

if you don’t want to buffer it then what you want is very specific, so you should just collect yourself (once) and save the first element for whatever way you want to get it, and then emit the other elements to a new flow, then you can suspend again on your emit(inside your collect) with the desired behaviour (no buffer as you just said)