how to convert `Flux<T>` to `Channel<T>` ?

# coroutines

[Robert Jaros]

how to convert Flux<T> to Channel<T> ?

[zak.taccardi]

do you mean Flow<T> to Flow<T>?

[zak.taccardi]

https://github.com/Kotlin/kotlinx.coroutines/tree/master/reactive/kotlinx-coroutines-reactor

[Robert Jaros]

there is only the reverse function ReceiveChannel.asFlux

[zak.taccardi]

it doesn’t make sense to convert from flux to channel

[zak.taccardi]

if you need it, you are likely doing something wrong

[Robert Jaros]

I have a websocket source which gives me Flux

[zak.taccardi]

so have a websocket source which gives you a Flow<T>

[Robert Jaros]

I have a service wanting the data as Channel<T>

[zak.taccardi]

unsubscribing from the websocket source should close it

[zak.taccardi]

this is what Flow<T> is for

[zak.taccardi]

the service is wrong then^^

[Robert Jaros]

I would like to connect one to another 🙂

[zak.taccardi]

https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/produce-in.html

[zak.taccardi]

you can do that, but it’s bad

[zak.taccardi]

the service should be updated to consume a Flow<T>

[Robert Jaros]

I know it probably should

[Robert Jaros]

thx for help