From eb78eefe5b234459f5e7c68a79571f592536af06 Mon Sep 17 00:00:00 2001 From: Chinmoy Chakraborty Date: Mon, 28 Aug 2023 14:17:49 +0530 Subject: [PATCH] Fix non subscribing call to updateQuestionAndAssessment method. --- .../java/com/uci/transformer/odk/ODKConsumerReactive.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/uci/transformer/odk/ODKConsumerReactive.java b/src/main/java/com/uci/transformer/odk/ODKConsumerReactive.java index 45b76d5..41e7a57 100644 --- a/src/main/java/com/uci/transformer/odk/ODKConsumerReactive.java +++ b/src/main/java/com/uci/transformer/odk/ODKConsumerReactive.java @@ -799,13 +799,13 @@ private Mono decodeXMessage(XMessage xMessage, ServiceResponse respons if (isEndOfForm(response)) { return appendNewResponse(formID, xMessage, response) .flatMap(resp -> replaceUserState(formID, xMessage, response)) - .flatMap(resp -> Mono.just(updateQuestionAndAssessment)) + .flatMap(resp -> Mono.defer(() -> Mono.fromCallable(updateQuestionAndAssessment::subscribe))) .flatMap(resp -> Mono.defer(() -> Mono.fromCallable(() -> new UploadService().submit(response.currentResponseState, restTemplate, customRestTemplate)))) .flatMap(resp -> Mono.just(getClone(nextMessage))); } else { return appendNewResponse(formID, xMessage, response) .flatMap(resp -> replaceUserState(formID, xMessage, response)) - .flatMap(resp -> Mono.just(updateQuestionAndAssessment)) + .flatMap(resp -> Mono.defer(() -> Mono.fromCallable(updateQuestionAndAssessment::subscribe))) .flatMap(resp -> Mono.just(getClone(nextMessage))); } }