diff options
Diffstat (limited to 'vespaclient-core/src/main/java/com/yahoo/feedhandler/ThreadedFeedAccess.java')
-rw-r--r-- | vespaclient-core/src/main/java/com/yahoo/feedhandler/ThreadedFeedAccess.java | 27 |
1 files changed, 6 insertions, 21 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedhandler/ThreadedFeedAccess.java b/vespaclient-core/src/main/java/com/yahoo/feedhandler/ThreadedFeedAccess.java index b5a507e894f..215ea6b9917 100644 --- a/vespaclient-core/src/main/java/com/yahoo/feedhandler/ThreadedFeedAccess.java +++ b/vespaclient-core/src/main/java/com/yahoo/feedhandler/ThreadedFeedAccess.java @@ -2,10 +2,9 @@ package com.yahoo.feedhandler; import com.yahoo.concurrent.ThreadFactoryFactory; -import com.yahoo.document.Document; -import com.yahoo.document.DocumentId; +import com.yahoo.document.DocumentPut; +import com.yahoo.document.DocumentRemove; import com.yahoo.document.DocumentUpdate; -import com.yahoo.document.TestAndSetCondition; import com.yahoo.feedapi.SimpleFeedAccess; import java.util.concurrent.Executor; @@ -40,14 +39,15 @@ final class ThreadedFeedAccess implements SimpleFeedAccess { }; } } + @Override - public void put(Document doc) { + public void put(DocumentPut doc) { executor.execute(() -> simpleFeedAccess.put(doc)); } @Override - public void remove(DocumentId docId) { - executor.execute(() -> simpleFeedAccess.remove(docId)); + public void remove(DocumentRemove remove) { + executor.execute(() -> simpleFeedAccess.remove(remove)); } @Override @@ -56,21 +56,6 @@ final class ThreadedFeedAccess implements SimpleFeedAccess { } @Override - public void put(Document doc, TestAndSetCondition condition) { - executor.execute(() -> simpleFeedAccess.put(doc, condition)); - } - - @Override - public void remove(DocumentId docId, TestAndSetCondition condition) { - executor.execute(() -> simpleFeedAccess.remove(docId, condition)); - } - - @Override - public void update(DocumentUpdate update, TestAndSetCondition condition) { - executor.execute(() -> simpleFeedAccess.update(update, condition)); - } - - @Override public boolean isAborted() { return simpleFeedAccess.isAborted(); } |