``` override fun safeHandle(message: Message<Me...
# codereview
f
Copy code
override 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)
                        }
                    } 
                }
        }