How can an initial value be loaded from a `suspend` function using something similar to `.scan(..)` ...

# coroutines

[zak.taccardi]

How can an initial value be loaded from a suspend function using something similar to .scan(..) with a SharedFlow?

.scan(loadInitialValueAsynchronously()) { .. }

I’m effectively trying to replace an actor with a SharedFlow.

Untitled

[zak.taccardi]

The best solution I’ve come up with is to use a Deferred<SharedFlow<State> and emit that as `

flow { emitAll(deferredStateFlow.await()) }

seems a little un-ergonomic though? is there a better solution?

Untitled.kt

[zak.taccardi]

I think

.shareIn(
  this,
  SharingStarted.Eagerly, // begin observing immediately!
  replay = 1
)

can be replaced with:

.stateIn(this)

which makes it a little nicer