summaryrefslogtreecommitdiffstats
path: root/vespaclient-core/src/main/java/com/yahoo/feedhandler/FeedResponse.java
diff options
context:
space:
mode:
Diffstat (limited to 'vespaclient-core/src/main/java/com/yahoo/feedhandler/FeedResponse.java')
-rwxr-xr-xvespaclient-core/src/main/java/com/yahoo/feedhandler/FeedResponse.java7
1 files changed, 5 insertions, 2 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedhandler/FeedResponse.java b/vespaclient-core/src/main/java/com/yahoo/feedhandler/FeedResponse.java
index 7492a48414b..738b4d3303a 100755
--- a/vespaclient-core/src/main/java/com/yahoo/feedhandler/FeedResponse.java
+++ b/vespaclient-core/src/main/java/com/yahoo/feedhandler/FeedResponse.java
@@ -35,6 +35,7 @@ public final class FeedResponse extends HttpResponse implements SharedSender.Res
private final RouteMetricSet metrics;
private boolean abortOnError = false;
private boolean isAborted = false;
+ private final SharedSender.Pending pendingNumber = new SharedSender.Pending();
public FeedResponse(RouteMetricSet metrics) {
super(com.yahoo.jdisc.http.HttpResponse.Status.OK);
@@ -101,7 +102,7 @@ public final class FeedResponse extends HttpResponse implements SharedSender.Res
return "";
}
- public boolean handleReply(Reply reply, int numPending) {
+ public boolean handleReply(Reply reply) {
metrics.addReply(reply);
if (reply.getTrace().getLevel() > 0) {
String str = reply.getTrace().toString();
@@ -128,9 +129,11 @@ public final class FeedResponse extends HttpResponse implements SharedSender.Res
return false;
}
}
- return numPending > 0;
+ return true;
}
+ public SharedSender.Pending getPending() { return pendingNumber; }
+
public void done() {
metrics.done();
}