Fix non subscribing call to updateQuestionAndAssessment method. (#96)

samagra-comms · Aug 28, 2023 · 488226a · 488226a
1 parent 5db2ec3
commit 488226a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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<XMessage> 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)));
         }
     }