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/08/31 16:01:05 UTC
cxf git commit: [CXF-6833] Adding a constructor
Repository: cxf
Updated Branches:
refs/heads/master 1224d5cc9 -> ec95dfbaf
[CXF-6833] Adding a constructor
Project: http://git-wip-us.apache.org/repos/asf/cxf/repo
Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/ec95dfba
Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/ec95dfba
Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/ec95dfba
Branch: refs/heads/master
Commit: ec95dfbaf9fae88d21c98305d6415c65c00fd2fa
Parents: 1224d5c
Author: Sergey Beryozkin <sb...@gmail.com>
Authored: Wed Aug 31 17:00:45 2016 +0100
Committer: Sergey Beryozkin <sb...@gmail.com>
Committed: Wed Aug 31 17:00:45 2016 +0100
----------------------------------------------------------------------
.../cxf/jaxrs/provider/rx/JsonStreamingAsyncSubscriber.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cxf/blob/ec95dfba/rt/rs/extensions/providers/src/main/java/org/apache/cxf/jaxrs/provider/rx/JsonStreamingAsyncSubscriber.java
----------------------------------------------------------------------
diff --git a/rt/rs/extensions/providers/src/main/java/org/apache/cxf/jaxrs/provider/rx/JsonStreamingAsyncSubscriber.java b/rt/rs/extensions/providers/src/main/java/org/apache/cxf/jaxrs/provider/rx/JsonStreamingAsyncSubscriber.java
index 5e36e9c..27384b1 100644
--- a/rt/rs/extensions/providers/src/main/java/org/apache/cxf/jaxrs/provider/rx/JsonStreamingAsyncSubscriber.java
+++ b/rt/rs/extensions/providers/src/main/java/org/apache/cxf/jaxrs/provider/rx/JsonStreamingAsyncSubscriber.java
@@ -25,7 +25,10 @@ public class JsonStreamingAsyncSubscriber<T> extends StreamingAsyncSubscriber<T>
this(ar, 1000);
}
public JsonStreamingAsyncSubscriber(AsyncResponse ar, long pollTimeout) {
- super(ar, "[", "]", ",", pollTimeout);
+ this(ar, pollTimeout, 0);
+ }
+ public JsonStreamingAsyncSubscriber(AsyncResponse ar, long pollTimeout, long asyncTimeout) {
+ super(ar, "[", "]", ",", pollTimeout, asyncTimeout);
}
}