or do I need to do `flow val result = client download url em kotlinlang #coroutines

Channels

lincheck

kobweb

koalaql

kotlin-multiplatform-contest

osgi

brikk

revolver

tricity-kotlin-user-group

cincinnati-user-group

prozis-android-backup

refactoring-to-kotlin

russian-kotlinasfirst

androidgithubprojects

navigation-architecture-component

stayhungrystayfoolish

practical-functional-programming

tensorflow

swagger-gradle-codegen

kotlinultimatechallenge

competitive-programming

skia-wasm-interop-temp

java-to-kotlin-refactoring

event21-community-content

myndocs-oauth2-server

jvm-ir-backend-feedback

Title

dave08

01/01/2020, 3:20 PM

or do I need to do

flow { val result = client.download(url); emit(result) }

instead of using

flowOf

Seems so... it wasn't so obvious though...

Dominaezzz

01/01/2020, 4:11 PM

yes

dave08

01/01/2020, 4:12 PM

Isn't there a shorter way for such a common pattern?

Dominaezzz

01/01/2020, 4:12 PM

flatMapMerge

is a bit of a hack. I'd recommend not using it for concurrency and just do

async

yourself.

https://github.com/Kotlin/kotlinx.coroutines/issues/1147

dave08

01/01/2020, 4:16 PM

Thanks! Good reference... is there any mention of why its a hack there and why async would be better?

Dominaezzz

01/01/2020, 4:17 PM

Maybe "hack" wasn't the right word but.... https://github.com/Kotlin/kotlinx.coroutines/issues/1147#issuecomment-487999918

dave08

01/01/2020, 4:24 PM

Ok, now I got you, but in the meantime I don't see why https://github.com/Kotlin/kotlinx.coroutines/issues/1147#issuecomment-487531313

shouldn't be a partial solution... the name makes it pretty explicit...

Dominaezzz

01/01/2020, 4:28 PM

Yeah it's not too bad.

dave08

01/01/2020, 4:30 PM

Just wondering what bufferSize is for if there's concurrencyLevel param...?

It seems like the implementation has to be adapted a little since buffer() was added, but I can't seem to add that too?

3 Views

#coroutines Join Slack