Modify the test expected results after fix of #1250

Author: lling

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

@@ -92,7 +92,7 @@ public void bulkInputEndpointTestWithRetry() {
         loader.awaitCompletion();
         checkDocuments("bulkInputTest_1");
         checkDocuments("bulkInputTest_2");
-        assertTrue("Number of documents written not as expected." + counter, counter >= 7);
+        assertTrue("Number of documents written not as expected." + counter, counter == 8);
     }
 
     @Test

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

@@ -31,6 +31,7 @@
 import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 
+import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertTrue;
 
 public class ErrorListenerInputOutputEndpointTest {
@@ -102,9 +103,9 @@ public void testInputOutputCallerWithRetry() {
         input.stream().forEach(value -> bulkCaller.accept(IOTestUtil.asInputStream(value)));
         bulkCaller.awaitCompletion();
 
-        //assertEquals("mismatch between input and output size"+input+":"+output, input.size(), output.size());
-        //assertEquals("mismatch between input and output elements", input, output);
-        assertTrue("wrong output size", output.size() <= 16 && output.size() >= 8);
+        assertEquals("mismatch between input and output size"+input+":"+output, input.size(), output.size());
+        assertEquals("mismatch between input and output elements", input, output);
+        assertTrue("wrong output size", output.size() == 16);
     }
 
     @Test