fstn
10/23/2017, 8:01 PMoverride fun safeHandle(message: Message<MessageBody>, messageBody: MessageBody, validEvents: List<String>): Observable<ServiceTaskResult> {
return NodeManager.get(messageBody)
.flatMap { lastNode ->
if (lastNode != null) {
val validEvents = FlowOrchestrator.getValidNextEvent(node, messageBody)
if (validEvents.isNotEmpty()) {
FlowOrchestrator.tryToDoNode(validEvents as MutableList<String>, lastNode, messageBody)
} else {
ServiceTaskResult(lastNode, messageBody)
}
}
}
}