Is there currently a way to implement some kind of...

# coroutines

[dave08]

Is there currently a way to implement some kind of share operator on Flow (at least in the meantime until it shows up in the library)? As in https://github.com/Kotlin/kotlinx.coroutines/issues/1261 ... broadcastIn and asFlow is probably hot... so a fast upstream might lead to lost emissions unless a buffer is properly configured...

[streetsofboston]

I wrote this:
https://gist.github.com/streetsofboston/39c3f8c882c9891b35e0ebc3cd812381
as part of this issue:
https://github.com/Kotlin/kotlinx.coroutines/issues/1086#issuecomment-485675107

[streetsofboston]

The gist linked above implements a Flow variation of ConnectableObservable in Rx, which would allow for the share and cache operators.

[dave08]

You use this in production? Also, couldn't this be simplified, since anyways the actual implementation might be different when it comes around... I guess what I'm looking for is more of a simple quick-and-dirty-but-for-sure-works solution 😉.

Although the Gist looks like a good idea 🙂, having a ConnectableFlow is much cleaner than returning a regular Flow ...

[streetsofboston]

Decisions have not yet been made by the JetBrains team. My issue (1086) and the related issue (1261) are still out standing.. not sure which one will be the one that is used….

[streetsofboston]

I have not used it in production, but I have a pretty good test-suite around it.

[dave08]

Meanwhile, I think people are just going to fill their code with `buffer()`ed `broadcastIn`s returning `ReceiveChannel`s and `asFlow()`s 🤕...

Thanks, I guess I'll take a look then.