diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2021-10-28 12:05:58 +0200 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2021-10-28 12:05:58 +0200 |
commit | 181309354f4550dd3decf1918ba9367b47eee256 (patch) | |
tree | fec8a4f28f6905da5f81729d3afa4a8272a4824d /vespaclient-container-plugin/src/test/java/com | |
parent | c89d584fde882f53101dc9fd417a57b44117cfc0 (diff) |
Stop writing documents once document array is closed
Diffstat (limited to 'vespaclient-container-plugin/src/test/java/com')
-rw-r--r-- | vespaclient-container-plugin/src/test/java/com/yahoo/document/restapi/resource/DocumentV1ApiTest.java | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/vespaclient-container-plugin/src/test/java/com/yahoo/document/restapi/resource/DocumentV1ApiTest.java b/vespaclient-container-plugin/src/test/java/com/yahoo/document/restapi/resource/DocumentV1ApiTest.java index 0e62b620828..412558f9a87 100644 --- a/vespaclient-container-plugin/src/test/java/com/yahoo/document/restapi/resource/DocumentV1ApiTest.java +++ b/vespaclient-container-plugin/src/test/java/com/yahoo/document/restapi/resource/DocumentV1ApiTest.java @@ -263,12 +263,13 @@ public class DocumentV1ApiTest { // Put some documents in the response parameters.getLocalDataHandler().onMessage(new PutDocumentMessage(new DocumentPut(doc1)), tokens.get(0)); parameters.getLocalDataHandler().onMessage(new PutDocumentMessage(new DocumentPut(doc2)), tokens.get(1)); - parameters.getLocalDataHandler().onMessage(new PutDocumentMessage(new DocumentPut(doc3)), tokens.get(2)); VisitorStatistics statistics = new VisitorStatistics(); statistics.setBucketsVisited(1); - statistics.setDocumentsVisited(3); + statistics.setDocumentsVisited(2); parameters.getControlHandler().onVisitorStatistics(statistics); parameters.getControlHandler().onDone(VisitorControlHandler.CompletionCode.TIMEOUT, "timeout is OK"); + // Extra documents are ignored. + parameters.getLocalDataHandler().onMessage(new PutDocumentMessage(new DocumentPut(doc3)), tokens.get(2)); }); response = driver.sendRequest("http://localhost/document/v1?cluster=content&bucketSpace=default&wantedDocumentCount=1025&concurrency=123" + "&selection=all%20the%20things&fieldSet=[id]&timeout=6&stream=true&slices=4&sliceId=1"); @@ -286,13 +287,9 @@ public class DocumentV1ApiTest { " \"fields\": {" + " \"artist\": \"Asa-Chan & Jun-Ray\"" + " }" + - " }," + - " {" + - " \"id\": \"id:space:music:g=a:three\"," + - " \"fields\": {}" + " }" + " ]," + - " \"documentCount\": 3" + + " \"documentCount\": 2" + "}", response.readAll()); assertEquals(200, response.getStatus()); |