diff --git a/spring-cloud-netflix.html b/spring-cloud-netflix.html index 31e865b1f..cf99eb082 100644 --- a/spring-cloud-netflix.html +++ b/spring-cloud-netflix.html @@ -3608,7 +3608,26 @@ info:
-
Unresolved directive in spring-cloud-netflix.adoc - include::../../../../spring-cloud-netflix-core/src/test/java/org/springframework/cloud/netflix/rx/SingleReturnValueHandlerTest.java[tags=rx_single,indent=0]
+
@RequestMapping(method = RequestMethod.GET, value = "/single")
+public Single<String> single() {
+	return Single.just("single value");
+}
+
+@RequestMapping(method = RequestMethod.GET, value = "/singleWithResponse")
+public ResponseEntity<Single<String>> singleWithResponse() {
+	return new ResponseEntity<>(Single.just("single value"),
+			HttpStatus.NOT_FOUND);
+}
+
+@RequestMapping(method = RequestMethod.GET, value = "/singleCreatedWithResponse")
+public Single<ResponseEntity<String>> singleOuterWithResponse() {
+	return Single.just(new ResponseEntity<>("single value", HttpStatus.CREATED));
+}
+
+@RequestMapping(method = RequestMethod.GET, value = "/throw")
+public Single<Object> error() {
+	return Single.error(new RuntimeException("Unexpected"));
+}
@@ -3616,7 +3635,34 @@ info:
-
Unresolved directive in spring-cloud-netflix.adoc - include::../../../../spring-cloud-netflix-core/src/test/java/org/springframework/cloud/netflix/rx/ObservableReturnValueHandlerTest.java[tags=rx_observable,indent=0]
+
@RequestMapping(method = RequestMethod.GET, value = "/single")
+public Single<String> single() {
+    return Observable.just("single value").toSingle();
+}
+
+@RequestMapping(method = RequestMethod.GET, value = "/multiple")
+public Single<List<String>> multiple() {
+    return Observable.just("multiple", "values").toList().toSingle();
+}
+
+@RequestMapping(method = RequestMethod.GET, value = "/responseWithObservable")
+public ResponseEntity<Single<String>> responseWithObservable() {
+
+    Observable<String> observable = Observable.just("single value");
+    HttpHeaders headers = new HttpHeaders();
+    headers.setContentType(APPLICATION_JSON_UTF8);
+    return new ResponseEntity<>(observable.toSingle(), headers, HttpStatus.CREATED);
+}
+
+@RequestMapping(method = RequestMethod.GET, value = "/timeout")
+public Observable<String> timeout() {
+    return Observable.timer(1, TimeUnit.MINUTES).map(new Func1<Long, String>() {
+        @Override
+        public String call(Long aLong) {
+            return "single value";
+        }
+    });
+}
@@ -3624,7 +3670,22 @@ info:
-
Unresolved directive in spring-cloud-netflix.adoc - include::../../../../spring-cloud-netflix-core/src/test/java/org/springframework/cloud/netflix/rx/ObservableSseEmitterTest.java[tags=rx_observable_sse,indent=0]
+
@RequestMapping(method = RequestMethod.GET, value = "/sse")
+public SseEmitter single() {
+	return RxResponse.sse(Observable.just("single value"));
+}
+
+@RequestMapping(method = RequestMethod.GET, value = "/messages")
+public SseEmitter messages() {
+	return RxResponse.sse(Observable.just("message 1", "message 2", "message 3"));
+}
+
+@RequestMapping(method = RequestMethod.GET, value = "/events")
+public SseEmitter event() {
+	return RxResponse.sse(APPLICATION_JSON_UTF8,
+			Observable.just(new EventDto("Spring io", getDate(2016, 5, 19)),
+					new EventDto("SpringOnePlatform", getDate(2016, 8, 1))));
+}