aboutsummaryrefslogtreecommitdiffstats
path: root/vespaclient-core
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-04-25 19:57:57 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2019-04-25 19:57:57 +0200
commit907158959c159904c3f4d20274c565806746ac15 (patch)
treef4db3e3d2fc81cf061cb1811b5bc3af4ca91695f /vespaclient-core
parent249fe76c9437d0f1a033294df98d8d8101baef2c (diff)
Refactor to allow for lazy decode.
Diffstat (limited to 'vespaclient-core')
-rw-r--r--vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java6
-rwxr-xr-xvespaclient-core/src/main/java/com/yahoo/feedapi/VespaFeedSender.java4
2 files changed, 5 insertions, 5 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java b/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java
index e354cba141d..a2bb2e8514b 100644
--- a/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java
+++ b/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java
@@ -10,6 +10,7 @@ import java.util.List;
import javax.xml.stream.XMLStreamException;
import com.yahoo.document.DocumentTypeManager;
+import com.yahoo.vespaxmlparser.FeedOperation;
import com.yahoo.vespaxmlparser.FeedReader;
import com.yahoo.vespaxmlparser.VespaXMLFeedReader;
@@ -80,14 +81,13 @@ public abstract class Feeder {
while (!sender.isAborted()) {
try {
- VespaXMLFeedReader.Operation op = new VespaXMLFeedReader.Operation();
- reader.read(op);
+ FeedOperation op = reader.read();
if (createIfNonExistent && op.getDocumentUpdate() != null) {
op.getDocumentUpdate().setCreateIfNonExistent(true);
}
// Done feeding.
- if (op.getType() == VespaXMLFeedReader.OperationType.INVALID) {
+ if (op.getType() == FeedOperation.Type.INVALID) {
break;
} else {
sender.sendOperation(op);
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedapi/VespaFeedSender.java b/vespaclient-core/src/main/java/com/yahoo/feedapi/VespaFeedSender.java
index b441e81a829..a1666a83856 100755
--- a/vespaclient-core/src/main/java/com/yahoo/feedapi/VespaFeedSender.java
+++ b/vespaclient-core/src/main/java/com/yahoo/feedapi/VespaFeedSender.java
@@ -1,7 +1,7 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.feedapi;
-import com.yahoo.vespaxmlparser.VespaXMLFeedReader;
+import com.yahoo.vespaxmlparser.FeedOperation;
/**
* Wrapper class for SimpleFeedAccess to send various XML operations.
@@ -18,7 +18,7 @@ public class VespaFeedSender {
return sender.isAborted();
}
- public void sendOperation(VespaXMLFeedReader.Operation op) {
+ public void sendOperation(FeedOperation op) {
switch (op.getType()) {
case DOCUMENT:
sender.put(op.getDocument(), op.getCondition());