1 files changed, 9 insertions, 4 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 cdd4ac76c4c..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();
@@ -123,12 +124,16 @@ public final class FeedResponse extends HttpResponse implements SharedSender.Res
                 log.finest(str);
                 addError(str);
             }
-            isAborted = abortOnError;
-            return !abortOnError;
+            if (abortOnError) {
+                isAborted = true;
+                return false;
+            }
         }
-        return numPending > 0;
+        return true;
     }
 
+    public SharedSender.Pending getPending() { return pendingNumber; }
+
     public void done() {
         metrics.done();
     }