channel_viewmodel

channel_viewmodel.kt

@HiltViewModel
class ChannelViewModel @Inject constructor(
  private val repository: ChannelRepository
) : ViewModel() {

  private val userFlow = repository.streamUserFlow()
  
  private val channelEvent: MutableSharedFlow<ChannelEvent> = publishedFlow()
  internal val channelUiState: SharedFlow<ChannelUiState> =
    combine(channelEvent, userFlow) { event, user ->
      event to user
    }.flatMapLatest { pair ->
      val (event, user) = pair
      when (event) {
        is ChannelEvent.JoinDefaultChannels -> {
          val response = repository.joinDefaultChannels(user = user)
          if (response.isSuccess) {
            flowOf(ChannelUiState.JoinSuccess)
          } else {
            flowOf(ChannelUiState.Error(response.messageOrNull))
          }
        }
        
        ..
    }.asStateFlow(ChannelUiState.Idle)
}