Eugen Martynov
10/23/2017, 7:43 PMif (validEvents.isEmpty())
validEvents.addAll(FlowOrchestrator.getValidNextEvent(node, messageBody))
return if (validEvents.isNotEmpty()) {
validEvents.toObservable().flatMap { notifyNextNode(node, it, messageBody) }
} else {
Observable.empty()
}