Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- fun save(multiMeasurement: Mono<MultiMeasurement>) =
- multiMeasurement.map(MultiMeasurement::validate)
- .flatMapMany { measurementCollector.save(it) }
- .doOnNext { eventSender.sendEvent(it.toMeasurementItem()) }
- .then(statusFacade.save(multiMeasurement))
- .doOnNext { eventSender.sendEvent(it.toStatusUpdateItem()) }
- .flatMap { toSettings(it.deviceId) }
- |_ Mono.flatMap ⇢ com.openbrewery.beerbob.status.StatusCollector.save(StatusCollector.kt:15)
- |_ Flux.then ⇢ com.openbrewery.beerbob.measurement.MeasurementFacade.save(MeasurementFacade.kt:21)
- |_ Mono.doOnNext ⇢ com.openbrewery.beerbob.measurement.MeasurementFacade.save(MeasurementFacade.kt:22)
- |_ Mono.flatMap ⇢ com.openbrewery.beerbob.measurement.MeasurementFacade.save(MeasurementFacade.kt:23)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement