Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public Flowable<TrainingParametersSummary> getTrainingParameterSummary(long id) {
- EndTrainingDataProcessor endTrainingDataProcessor = new EndTrainingDataProcessor();
- return trainingSummaryRepository.getTrainingSummaryAsSingle(id)
- .flatMap(trainingSummaryRow -> externalStorageDatabase.readTrainingLocationData(
- trainingSummaryRow.getStartTimestamp().toString()
- ))
- .toFlowable()
- .flatMapIterable(trainingPoints -> trainingPoints)
- .map(trainingPoint -> {
- Location location = new Location(LocationManager.GPS_PROVIDER);
- location.setLatitude(trainingPoint.getLatitude());
- location.setLongitude(trainingPoint.getLongitude());
- return location;
- })
- .doOnNext(endTrainingDataProcessor::process)
- .doOnError(e -> Log.i(TAG, "getTrainingParameterSummary: " + e.getMessage()))
- .map(location -> endTrainingDataProcessor.getTrainingParametersSummary())
- .subscribeOn(Schedulers.io());
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement