You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by se...@apache.org on 2016/04/29 15:21:59 UTC
cxf git commit: [CXF-6833] Adding a HelloWorld async server test
Repository: cxf
Updated Branches:
refs/heads/master 6c324421a -> 4786e8325
[CXF-6833] Adding a HelloWorld async server test
Project: http://git-wip-us.apache.org/repos/asf/cxf/repo
Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/4786e832
Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/4786e832
Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/4786e832
Branch: refs/heads/master
Commit: 4786e832573f1fcc07ed190ab21fdb2820348e4d
Parents: 6c32442
Author: Sergey Beryozkin <sb...@gmail.com>
Authored: Fri Apr 29 14:21:39 2016 +0100
Committer: Sergey Beryozkin <sb...@gmail.com>
Committed: Fri Apr 29 14:21:39 2016 +0100
----------------------------------------------------------------------
.../jaxrs/reactive/JAXRSReactiveTest.java | 7 ++++
.../systest/jaxrs/reactive/ReactiveService.java | 36 ++++++++++++++++++++
2 files changed, 43 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cxf/blob/4786e832/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/JAXRSReactiveTest.java
----------------------------------------------------------------------
diff --git a/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/JAXRSReactiveTest.java b/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/JAXRSReactiveTest.java
index 0241fed..c92e8fa 100644
--- a/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/JAXRSReactiveTest.java
+++ b/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/JAXRSReactiveTest.java
@@ -42,6 +42,13 @@ public class JAXRSReactiveTest extends AbstractBusClientServerTestBase {
String text = wc.accept("text/plain").get(String.class);
assertEquals("Hello, world!", text);
}
+ @Test
+ public void testGetHelloWorldAsyncText() throws Exception {
+ String address = "http://localhost:" + PORT + "/reactive/textAsync";
+ WebClient wc = WebClient.create(address);
+ String text = wc.accept("text/plain").get(String.class);
+ assertEquals("Hello, world!", text);
+ }
}
http://git-wip-us.apache.org/repos/asf/cxf/blob/4786e832/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/ReactiveService.java
----------------------------------------------------------------------
diff --git a/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/ReactiveService.java b/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/ReactiveService.java
index 87ab35a..7127214 100644
--- a/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/ReactiveService.java
+++ b/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/ReactiveService.java
@@ -23,8 +23,11 @@ package org.apache.cxf.systest.jaxrs.reactive;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
+import javax.ws.rs.container.AsyncResponse;
+import javax.ws.rs.container.Suspended;
import rx.Observable;
+import rx.Subscriber;
@Path("/reactive")
@@ -37,6 +40,39 @@ public class ReactiveService {
return Observable.just("Hello, world!");
}
+ @GET
+ @Produces("text/plain")
+ @Path("textAsync")
+ public void getTextAsync(@Suspended final AsyncResponse ar) {
+ Observable.just("Hello, ").map(s -> s + "world!")
+ .subscribe(new AsyncResponseSubscriber(ar));
+
+ }
+
+ private class AsyncResponseSubscriber extends Subscriber<String> {
+
+ private StringBuilder sb = new StringBuilder();
+ private AsyncResponse ar;
+
+ AsyncResponseSubscriber(AsyncResponse ar) {
+ this.ar = ar;
+ }
+ @Override
+ public void onCompleted() {
+ ar.resume(sb.toString());
+ }
+
+ @Override
+ public void onError(Throwable arg0) {
+ // TODO Auto-generated method stub
+ }
+
+ @Override
+ public void onNext(String s) {
+ sb.append(s);
+ }
+
+ }
}