fstn
10/23/2017, 8:14 PMprivate fun ok(messageBody: MessageBody, validEvents: List<String>): Observable<Message<MessageBody>> {
if (logger.isDebugEnabled) {
logger.debug(“Ok called for node ${node.id}“)
}
return FlowOrchestrator.tryToDoNode(validEvents, node, messageBody)
.toObservable()
.filter { it != null }
.flatMap { send(it.eventName, it.messageBody) }
}