Flow state machine

FlowStateMachine.kt

open class FlowStateMachine<G: Any, U: Any>(
  init: () -> CommonMachineState<G, U>
) : CommonStateMachine.Base<G, U>(init) {
  
  private val mediator = MutableSharedFlow<U>(
    replay = 1, 
    onBufferOverflow = BufferOverflow.DROP_OLDEST
  )
  
  init {
     start()
  }

  /**
   * ExportedUI state
   */
  val uiState: SharedFlow<U> = mediator.asSharedFlow()

  final override fun setUiState(uiState: U) {
    mediator.tryEmit(uiState)
  }
}