suspend fun dispatch()

in server/src/main/kotlin/com/jetbrains/teamcity/plugins/unrealengine/server/EventBus.kt [69:74]

• 6 lines of code
• 1 McCabe index (conditional complexity)

    suspend fun dispatch(event: T) {
        val partitionKey = partitioner(event)
        val workerNumber = partitionKey % workerChannels.size
        logger.debug("Dispatching new event to bus \"${config.name}\", partition key = $partitionKey, assigned worker = $workerNumber")
        workerChannels[workerNumber].send(event)
    }