I recently migrated from

PublishSubject.create<T>()

to

MutableSharedFlow<T>(replay = 0, extraBufferCapacity = 1)

, but what I can't wrap my head around is what is the use case for

MutableSharedFlow<T>()

? (both parameters set to zero by default). It doesn't really seem to do anything.

MutableStateFlow is like BehaviourSubject, so it replay = 1 and onBufferOverflow = DROP_OLDEST

Ah sorry, meant default constructor for MutableSharedFlow 😅

It doesn’t really seem to do anything

Isn’t it emit if it already have subscribers? I didn’t try, just asking Also default constructor uses Suspend overflow policty, so emitter will suspend in this case

I tried it very shortly and it seemed like it didn't emit to existing subscribers until I added the extra buffer capacity. But I was using tryEmit to post values instead of the suspending emit

. But I was using tryEmit to post values instead of the suspending emit

Probably this why you have this problem, tryEmit will just drop value

Ah that makes a lot of sense, thanks :)