Tests for empty observable

jmnarloch · Nov 28, 2016 · d6d4db5 · d6d4db5
1 parent 29a4ec7
commit d6d4db5
Show file tree

Hide file tree

Showing 2 changed files with 36 additions and 2 deletions.
diff --git a/src/test/java/io/jmnarloch/spring/boot/rxjava/async/ObservableDeferredResultTest.java b/src/test/java/io/jmnarloch/spring/boot/rxjava/async/ObservableDeferredResultTest.java
@@ -69,6 +69,11 @@ public class ObservableDeferredResultTest {
     @RestController
     protected static class Application {
 
+        @RequestMapping(method = RequestMethod.GET, value = "/empty")
+        public ObservableDeferredResult<String> empty() {
+            return new ObservableDeferredResult<String>(Observable.<String>empty());
+        }
+
         @RequestMapping(method = RequestMethod.GET, value = "/single")
         public ObservableDeferredResult<String> single() {
             return new ObservableDeferredResult<String>(Observable.just("single value"));
@@ -105,6 +110,18 @@ public String call(Long aLong) {
         }
     }
 
+    @Test
+    public void shouldRetrieveEmptyResponse() {
+
+        // when
+        ResponseEntity<List> response = restTemplate.getForEntity(path("/empty"), List.class);
+
+        // then
+        assertNotNull(response);
+        assertEquals(HttpStatus.OK, response.getStatusCode());
+        assertEquals(Collections.emptyList(), response.getBody());
+    }
+
     @Test
     public void shouldRetrieveSingleValue() {
 
@@ -168,4 +185,4 @@ public void shouldTimeoutOnConnection() {
     private String path(String context) {
         return String.format("http://localhost:%d%s", port, context);
     }
-}
+}
diff --git a/src/test/java/io/jmnarloch/spring/boot/rxjava/mvc/ObservableReturnValueHandlerTest.java b/src/test/java/io/jmnarloch/spring/boot/rxjava/mvc/ObservableReturnValueHandlerTest.java
@@ -64,6 +64,11 @@ public class ObservableReturnValueHandlerTest {
     @RestController
     protected static class Application {
 
+        @RequestMapping(method = RequestMethod.GET, value = "/empty")
+        public Observable<Void> empty() {
+            return Observable.empty();
+        }
+
         @RequestMapping(method = RequestMethod.GET, value = "/single")
         public Observable<String> single() {
             return Observable.just("single value");
@@ -90,6 +95,18 @@ public String call(Long aLong) {
         }
     }
 
+    @Test
+    public void shouldRetrieveEmptyResponse() {
+
+        // when
+        ResponseEntity<List> response = restTemplate.getForEntity(path("/empty"), List.class);
+
+        // then
+        assertNotNull(response);
+        assertEquals(HttpStatus.OK, response.getStatusCode());
+        assertEquals(Collections.emptyList(), response.getBody());
+    }
+
     @Test
     public void shouldRetrieveSingleValue() {
 
@@ -139,4 +156,4 @@ public void shouldTimeoutOnConnection() {
     private String path(String context) {
         return String.format("http://localhost:%d%s", port, context);
     }
-}
+}