diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-06-09 11:24:02 +0200 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-06-09 11:24:02 +0200 |
commit | d29f603291096e0df578fca57a23c603124ddd03 (patch) | |
tree | 7c5494c7221477e6a6e49e383cc0277424958d71 /vespa-feed-client/src/test | |
parent | 9d3a6c0a90d11e7cabf889c16c6c7a025ce39712 (diff) |
Make client mock mark async operations as completed
Diffstat (limited to 'vespa-feed-client/src/test')
-rw-r--r-- | vespa-feed-client/src/test/java/ai/vespa/feed/client/JsonFeederTest.java | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/vespa-feed-client/src/test/java/ai/vespa/feed/client/JsonFeederTest.java b/vespa-feed-client/src/test/java/ai/vespa/feed/client/JsonFeederTest.java index 60f6b3a4e73..f50bd75bd4b 100644 --- a/vespa-feed-client/src/test/java/ai/vespa/feed/client/JsonFeederTest.java +++ b/vespa-feed-client/src/test/java/ai/vespa/feed/client/JsonFeederTest.java @@ -45,22 +45,26 @@ class JsonFeederTest { @Override public CompletableFuture<Result> put(DocumentId documentId, String documentJson, OperationParameters params) { ids.add(documentId.userSpecific()); - return new CompletableFuture<>(); + return createSuccessResult(documentId); } @Override public CompletableFuture<Result> update(DocumentId documentId, String updateJson, OperationParameters params) { - return new CompletableFuture<>(); + return createSuccessResult(documentId); } @Override public CompletableFuture<Result> remove(DocumentId documentId, OperationParameters params) { - return new CompletableFuture<>(); + return createSuccessResult(documentId); } @Override public void close(boolean graceful) { } + private CompletableFuture<Result> createSuccessResult(DocumentId documentId) { + return CompletableFuture.completedFuture(new Result(Result.Type.success, documentId, "success", null)); + } + }).build().feedMany(in, 1 << 7, false); // TODO: hangs when buffer is smaller than largest document System.err.println((json.length() / 1048576.0) + " MB in " + (System.nanoTime() - startNanos) * 1e-9 + " seconds"); assertEquals(docs + 1, ids.size()); |