Default action processor implementation

DefaultActionProcessor.kt

class DefaultActionProcessor(
    private val getUserListRepository: GetUserListRepository,
    private val connectivityMonitor: ConnectivityMonitor,
    private val logger: Logger,
    private val tracker: Tracker,
) : ActionProcessor<Action, Mutation, Event> {
    override fun invoke(action: Action): Flow<Pair<Mutation?, Event?>> =
        flow {
            when (action) {
                is Action.Load -> load()
                ...
            }
        }

    private suspend fun FlowCollector<Pair<Mutation?, Event?>>.load() {
        emit(Mutation.ShowLoader to null)

        when (val result = getUserListRepository()) {
            is Success -> {
                tracker.trackEvent(CatalogFetched)
                emit(Mutation.ShowContent(users = result.users) to null)
            }
            is Empty -> {
                tracker.trackEvent(EmptyCatalogFetched)
                logger.error("empty catalog")
                emit(Mutation.ShowContent(users = result.users) to null)
                
            }
            is Failure -> {
                tracker.trackEvent(CatalogFetchFailed)
                logger.error("failed catalog ${result.errorType}")
                emit(Mutation.ShowError(result.errorType)) to null)
            }
        }
    }
     
    ...
}