chore: implement endRecord function

Author: TimothyJones

src/main/java/io/contract_testing/contractcase/BoundaryExceptionMapper.java

@@ -18,19 +18,19 @@ static BoundaryFailure map(Exception e) {
   }
 
   static BoundaryFailure mapAsTriggerFailure(Exception e) {
-    return new BoundaryFailure(BoundaryFailureKindConstants.CASE_TRIGGER_ERROR, e.getMessage(),
+    return new BoundaryFailure(BoundaryFailureKindConstants.CASE_TRIGGER_ERROR, "Trigger function failed: " + e.getMessage(),
         stackTraceToString(e));
   }
 
   static BoundaryFailure mapAsVerifyFailure(Exception e) {
-    return new BoundaryFailure(BoundaryFailureKindConstants.CASE_VERIFY_RETURN_ERROR,
+    return new BoundaryFailure("Verification failed: " +  BoundaryFailureKindConstants.CASE_VERIFY_RETURN_ERROR,
         e.getMessage(),
         stackTraceToString(e));
   }
 
   public static BoundaryResult mapAsStateFailure(Exception e) {
     return new BoundaryFailure(BoundaryFailureKindConstants.CASE_CONFIGURATION_ERROR,
-        "State handler failed with" + e.getMessage(),
+        "State handler failed: " + e.getMessage(),
         stackTraceToString(e));
   }
 }

src/main/java/io/contract_testing/contractcase/ContractDefiner.java

@@ -24,6 +24,10 @@ public ContractDefiner(final @NotNull ContractCaseConfig config) {
     this.definer = definer;
   }
 
+  public void endRecord() {
+    BoundaryResultMapper.map(this.definer.endRecord());
+  }
+
   public <T, M extends AnyMockDescriptor> void runExample(ExampleDefinition<M> definition,
       final @NotNull IndividualSuccessTestConfig<T> additionalConfig) {
     try {

src/main/java/io/contract_testing/contractcase/client/InternalDefinerClient.java

@@ -136,7 +136,7 @@ private void completeWait(String id, ContractCaseStream.BoundaryResult result) {
   }
 
   private void maintainerLog(String s) {
-    System.err.println(s);
+    /*System.err.println(s);*/
   }
 
   private void sendResponse(Builder builder, String id) {
@@ -205,14 +205,11 @@ private BoundaryResult begin(ContractCaseConfig wireConfig) {
 
 
   public @NotNull BoundaryResult endRecord() {
-    requestObserver.onNext(DefinitionRequest.newBuilder()
-        .setEndDefinition(EndDefinitionRequest.newBuilder().build())
-        .build());
-
+    var result = executeCallAndWait(DefinitionRequest.newBuilder()
+        .setEndDefinition(EndDefinitionRequest.newBuilder().build()));
     requestObserver.onCompleted();
-    return new BoundaryFailure(BoundaryFailureKindConstants.CASE_CORE_ERROR,
-        "endRecord not implemented",
-        CONTRACT_CASE_JAVA_WRAPPER); // TODO
+
+    return result;
   }
 
   public @NotNull BoundaryResult runExample(JsonNode definition,