MLE-27481 Polaris fixes

Author: rjrudin

marklogic-client-api/src/main/java/com/marklogic/client/impl/OkHttpServices.java

@@ -2643,7 +2643,7 @@ private void putPostValueImpl(RequestLogger reqlog, String method,
 
 			Object nextValue = (handle != null) ? handle.sendContent() : value;
 
-			RequestBody sentValue = null;
+			RequestBody sentValue;
 			if (nextValue instanceof OutputStreamSender) {
 				sentValue = new StreamingOutputImpl(
 					(OutputStreamSender) nextValue, reqlog, mediaType);
@@ -2676,9 +2676,7 @@ private void putPostValueImpl(RequestLogger reqlog, String method,
 					requestBldr = addTelemetryAgentId(requestBldr);
 				}
 
-				response = (sentValue == null) ?
-					sendRequestOnce(requestBldr.put(null).build()) :
-					sendRequestOnce(requestBldr.put(sentValue).build());
+				response = sendRequestOnce(requestBldr.put(sentValue).build());
 			} else if ("post".equals(method)) {
 				if (requestBldr == null) {
 					connectPath = type;
@@ -2688,9 +2686,7 @@ private void putPostValueImpl(RequestLogger reqlog, String method,
 					requestBldr = addTelemetryAgentId(requestBldr);
 				}
 
-				response = (sentValue == null) ?
-					sendRequestOnce(requestBldr.post(RequestBody.create("", null)).build()) :
-					sendRequestOnce(requestBldr.post(sentValue).build());
+				response = sendRequestOnce(requestBldr.post(sentValue).build());
 			} else {
 				throw new MarkLogicInternalException("unknown method type "
 					+ method);
@@ -2950,7 +2946,10 @@ public Response apply(Request.Builder funcBuilder) {
 
 		updateDescriptor(outputBase, response.headers());
 		if (as != null) {
-			outputBase.receiveContent(makeResult(reqlog, "read", "resource", response, as));
+			Object result = makeResult(reqlog, "read", "resource", response, as);
+			if (result != null) {
+				outputBase.receiveContent(result);
+			}
 		} else {
 			closeResponse(response);
 		}
@@ -3035,7 +3034,10 @@ public Response apply(Request.Builder funcBuilder) {
 			ResponseStatus.OK_OR_CREATED_OR_NO_CONTENT);
 
 		if (as != null) {
-			outputBase.receiveContent(makeResult(reqlog, "write", "resource", response, as));
+			Object result = makeResult(reqlog, "write", "resource", response, as);
+			if (result != null) {
+				outputBase.receiveContent(result);
+			}
 		} else {
 			closeResponse(response);
 		}
@@ -3903,7 +3905,10 @@ public Response apply(Request.Builder funcBuilder) {
 			ResponseStatus.OK_OR_NO_CONTENT);
 
 		if (as != null) {
-			outputBase.receiveContent(makeResult(reqlog, "delete", "resource", response, as));
+			Object result = makeResult(reqlog, "delete", "resource", response, as);
+			if (result != null) {
+				outputBase.receiveContent(result);
+			}
 		} else {
 			closeResponse(response);
 		}