in stop case, throw error before all input is consumed #1250

Author: ehennum

marklogic-client-api/src/test/java/com/marklogic/client/test/dataservices/ErrorListenerInputOutputEndpointTest.java

@@ -55,10 +55,10 @@ public void testInputOutputCallerWithRetry() {
 
 
         String              endpointState = "{\"next\":1}";
-        String              endpointConstants      = "{\"max\":4,\"collection\":\"bulkInputOutputTest_1\"}";
+        String              endpointConstants      = "{\"errorOnMax\":false, \"max\":4,\"collection\":\"bulkInputOutputTest_1\"}";
 
         String              endpointState1 = "{\"next\":1}";
-        String              endpointConstants1      = "{\"max\":4,\"collection\":\"bulkInputOutputTest_2\"}";
+        String              endpointConstants1      = "{\"errorOnMax\":false, \"max\":4,\"collection\":\"bulkInputOutputTest_2\"}";
         Set<String>         input          = IOTestUtil.setOf(
                 "{\"docNum\":1, \"docName\":\"doc1\"}",
                 "{\"docNum\":2, \"docName\":\"doc2\"}",
@@ -113,10 +113,10 @@ public void testInputOutputCallerWithSkip() {
 
 
         String              endpointState = "{\"next\":1}";
-        String              endpointConstants      = "{\"max\":4,\"collection\":\"bulkInputOutputTest_1\"}";
+        String              endpointConstants      = "{\"errorOnMax\":false, \"max\":4,\"collection\":\"bulkInputOutputTest_1\"}";
 
         String              endpointState1 = "{\"next\":1}";
-        String              endpointConstants1      = "{\"max\":4,\"collection\":\"bulkInputOutputTest_2\"}";
+        String              endpointConstants1      = "{\"errorOnMax\":false, \"max\":4,\"collection\":\"bulkInputOutputTest_2\"}";
         Set<String>         input          = IOTestUtil.setOf(
                 "{\"docNum\":1, \"docName\":\"doc1\"}",
                 "{\"docNum\":2, \"docName\":\"doc2\"}",
@@ -167,10 +167,10 @@ public void testInputOutputCallerWithStop() throws IOException {
 
 
         String              endpointState = "{\"next\":1}";
-        String              endpointConstants      = "{\"max\":4,\"collection\":\"bulkInputOutputTest_1\"}";
+        String              endpointConstants      = "{\"errorOnMax\":true, \"max\":4,\"collection\":\"bulkInputOutputTest_1\"}";
 
         String              endpointState1 = "{\"next\":1}";
-        String              endpointConstants1      = "{\"max\":4,\"collection\":\"bulkInputOutputTest_2\"}";
+        String              endpointConstants1      = "{\"errorOnMax\":true, \"max\":4,\"collection\":\"bulkInputOutputTest_2\"}";
         Set<String>         input          = IOTestUtil.setOf(
                 "{\"docNum\":1, \"docName\":\"doc1\"}",
                 "{\"docNum\":2, \"docName\":\"doc2\"}",

marklogic-client-api/src/test/resources/dataservices/errorListenerBulkIOInputOutputCaller.sjs

@@ -18,8 +18,8 @@ const inputs =
                                   [ {UNKNOWN: input} ];
 
 //console.log(work.collection + ": state.next = " + state.next);
-var ranInt = Math.floor(Math.random() * Math.floor(2));
-if (ranInt == 1 && work.collection == "bulkInputOutputTest_1") {
+var ranInt =  Math.floor(Math.random() * Math.floor(2));
+if ((ranInt == 1 && work.collection == "bulkInputOutputTest_1") || (work.errorOnMax === true && state.next > work.max)) {
     //console.log(work.collection + ': ' + "state.next = " + state.next + ", ranInt = " + ranInt);
     fn.error(xs.QName("ERROR"), "Exception");
 }