override suspend fun consume()

in server/src/main/kotlin/com/jetbrains/teamcity/plugins/unrealengine/server/buildgraph/BuildGraphBadgePublisher.kt [40:53]


    override suspend fun consume(event: DistributedBuildStateChanged) {
        when (val result = either { handleStateChange(event) }) {
            is Either.Left ->
                when (val error = result.value) {
                    is ProcessingSkipped ->
                        logger.debug("State update for the build ${event.buildId} skipped because: ${error.reason}")
                    is GenericError ->
                        logger.logError(error, "An unexpected error occurred processing state update for the build ${event.buildId}:")
                }
            is Either.Right -> {
                logger.debug("State update for the build ${event.buildId} processed successfully")
            }
        }
    }