itsusmon

/**
* Inspired by Jaewoong Eum's flow-operators library (https://github.com/skydoves/flow-operators).
*/

class Restartable {

    private val restartFlow = MutableSharedFlow<SharingCommand>(extraBufferCapacity = 2)

    fun restart() {
        restartFlow.tryEmit(SharingCommand.STOP_AND_RESET_REPLAY_CACHE)