Add missing block() calls

src/main/java/guru/springframework/controllers/IngredientController.java

@@ -36,7 +36,7 @@ public String listIngredients(@PathVariable String recipeId, Model model){
         log.debug("Getting ingredient list for recipe id: " + recipeId);
 
         // use command object to avoid lazy load errors in Thymeleaf.
-        model.addAttribute("recipe", recipeService.findCommandById(recipeId));
+        model.addAttribute("recipe", recipeService.findCommandById(recipeId).block());
 
         return "recipe/ingredient/list";
     }

src/test/java/guru/springframework/services/ImageServiceImplTest.java

@@ -45,7 +45,7 @@ public void saveImageFile() throws Exception {
         ArgumentCaptor<Recipe> argumentCaptor = ArgumentCaptor.forClass(Recipe.class);
 
         //when
-        imageService.saveImageFile(id, multipartFile);
+        imageService.saveImageFile(id, multipartFile).block();
 
         //then
         verify(recipeReactiveRepository, times(1)).save(argumentCaptor.capture());

src/test/java/guru/springframework/services/IngredientServiceImplTest.java

@@ -123,7 +123,7 @@ public void testDeleteById() throws Exception {
         when(recipeReactiveRepository.save(any())).thenReturn(Mono.just(recipe));
 
         //when
-        ingredientService.deleteById("1", "3");
+        ingredientService.deleteById("1", "3").block();
 
         //then
         verify(recipeReactiveRepository, times(1)).findById(anyString());

src/test/java/guru/springframework/services/RecipeServiceImplTest.java

@@ -13,7 +13,6 @@
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
-import java.util.HashSet;
 import java.util.List;
 
 import static org.junit.Assert.assertEquals;
@@ -81,8 +80,6 @@ public void getRecipeCommandByIdTest() throws Exception {
     public void getRecipesTest() throws Exception {
 
         Recipe recipe = new Recipe();
-        HashSet receipesData = new HashSet();
-        receipesData.add(recipe);
 
         when(recipeService.getRecipes()).thenReturn(Flux.just(recipe));
 
@@ -102,7 +99,7 @@ public void testDeleteById() throws Exception {
         when(recipeReactiveRepository.deleteById(anyString())).thenReturn(Mono.empty());
 
         //when
-        recipeService.deleteById(idToDelete);
+        recipeService.deleteById(idToDelete).block();
 
         //then
         verify(recipeReactiveRepository, times(1)).deleteById(anyString());