how to convert `Flux<T>` to `Channel<T>...
# coroutinesr
Robert Jaros
10/08/2019, 5:42 PMhow to convert
Flux<T>Channel<T>z
zak.taccardi
10/08/2019, 5:43 PMdo you mean
Flow<T>Flow<T>zak.taccardi
10/08/2019, 5:44 PMr
Robert Jaros
10/08/2019, 5:45 PMthere is only the reverse function
ReceiveChannel.asFluxz
zak.taccardi
10/08/2019, 5:45 PMit doesn’t make sense to convert from flux to channel
zak.taccardi
10/08/2019, 5:45 PMif you need it, you are likely doing something wrong
r
Robert Jaros
10/08/2019, 5:46 PMI have a websocket source which gives me Flux
z
zak.taccardi
10/08/2019, 5:46 PMso have a websocket source which gives you a
Flow<T>r
Robert Jaros
10/08/2019, 5:47 PMI have a service wanting the data as Channel<T>
z
zak.taccardi
10/08/2019, 5:47 PMunsubscribing from the websocket source should close it
zak.taccardi
10/08/2019, 5:47 PMthis is what
Flow<T>zak.taccardi
10/08/2019, 5:47 PMthe service is wrong then^^
r
Robert Jaros
10/08/2019, 5:47 PMI would like to connect one to another 🙂
z
zak.taccardi
10/08/2019, 5:49 PMzak.taccardi
10/08/2019, 5:49 PMyou can do that, but it’s bad
zak.taccardi
10/08/2019, 5:50 PMthe service should be updated to consume a
Flow<T>r
Robert Jaros
10/08/2019, 5:53 PMI know it probably should
Robert Jaros
10/08/2019, 5:55 PMthx for help
👍 1
5 Views