fstn
10/25/2017, 12:33 PMreturn vertx.rxExecuteBlocking<List<String>> { future ->
val eventNamesToEmit = mutableListOf<String>()
eventNamesToEmit.addAll(
node.outgoingLinks
.filter { it.checkCondition(messageBody) }
.map { it.eventName }
)
if (eventNamesToEmit.isEmpty()) {
eventNamesToEmit.addAll(
node.outgoingLinks
.filter { it is ConditionalLink }
.filter { (it as ConditionalLink).condition == Condition.ELSE }
.map { it.eventName }
)
}
future.complete(eventNamesToEmit)
}