I'm wondering how to structure the code inside the...

# coroutines

[Maciek]

I'm wondering how to structure the code inside the class where I need something like an interval from RxJava, that'll do heavy operation every 50ms. The problem is that I'd want the channel producer to execute heavy operation only when someone is collecting the flow. I don't want to waste resources. Is there some easy way to achieve it?

Untitled.kt

[Dominaezzz]

Are you going to have multiple collectors?

[Maciek]

only one, but it can resubscribe multiple times

[Dominaezzz]

You'll probably want a SharedFlow , which will let you pause production based on subscriberCount . It hasn't been released yet though.....

[Dominaezzz]

Since you have the guarantee of one collector. You can always just use flow { /* loop and emit */ }

[Dominaezzz]

(Sans the channel)

[Maciek]

do you mean like that? Can't wrap my head around how otherwise I could expose the flow as a field that is created inside a method

Untitled

[Dominaezzz]

Is the initialize method strictly necessary?

[Dominaezzz]

Just initialise the flow at construction and it won't run until there is a subscriber.

[Maciek]

unfortunately it is, the snippet is simplified. For heavy operation, I need stuff from initialize method

[Dominaezzz]

In that case, you could use a CompletableDeferred and complete it in the initialize method with heavy result. The you can consume the CompletableDeferred in the flow. This also means that if flow collectors will suspend until initialize is called.