Add RequestContent

sdk/core/azure-core/src/main/java/com/azure/core/implementation/util/ArrayContent.java

@@ -0,0 +1,38 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.core.implementation.util;
+
+import com.azure.core.util.RequestContent;
+import com.azure.core.util.RequestOutbound;
+import reactor.core.publisher.Mono;
+
+/**
+ * A {@link RequestContent} implementation which is backed by a {@code byte[]}.
+ */
+public final class ArrayContent extends RequestContent {
+    private final byte[] content;
+    private final int offset;
+    private final int length;
+
+    public ArrayContent(byte[] content, int offset, int length) {
+        this.content = content;
+        this.offset = offset;
+        this.length = length;
+    }
+
+    @Override
+    public Mono<Void> writeToAsync(RequestOutbound requestOutbound) {
+        return Mono.defer(() -> Mono.fromRunnable(() -> writeTo(requestOutbound)));
+    }
+
+    @Override
+    public void writeTo(RequestOutbound requestOutbound) {
+
+    }
+
+    @Override
+    public Long attemptToGetLength() {
+        return (long) length;
+    }
+}

sdk/core/azure-core/src/main/java/com/azure/core/implementation/util/package-info.java

@@ -0,0 +1,7 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+/**
+ * Package containing implementation utilities.
+ */
+package com.azure.core.implementation.util;

sdk/core/azure-core/src/main/java/com/azure/core/util/RequestContent.java

@@ -0,0 +1,100 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.core.util;
+
+import com.azure.core.implementation.util.ArrayContent;
+import com.azure.core.util.serializer.ObjectSerializer;
+import reactor.core.publisher.Mono;
+
+import java.nio.charset.StandardCharsets;
+import java.util.Objects;
+
+/**
+ * Represents the content sent as part of a request.
+ */
+public abstract class RequestContent {
+    /**
+     * Write the {@link RequestContent} to the {@link RequestOutbound}.
+     *
+     * @param requestOutbound The outbound where the request will be written.
+     * @return An asynchronous response which will emit once the request has completed writing.
+     */
+    public abstract Mono<Void> writeToAsync(RequestOutbound requestOutbound);
+
+    /**
+     * Write the {@link RequestContent} to the {@link RequestOutbound}.
+     *
+     * @param requestOutbound The outbound where the request will be written.
+     */
+    public abstract void writeTo(RequestOutbound requestOutbound);
+
+    /**
+     * Gets the length of the {@link RequestContent}, if it is able to be calculated.
+     *
+     * @return The length of the {@link RequestContent}, if it is able to be calculated.
+     */
+    public abstract Long attemptToGetLength();
+
+    /**
+     * Creates a {@link RequestContent} comprised of the {@code bytes}.
+     *
+     * @param bytes The bytes that will be the {@link RequestContent} data.
+     * @return A new {@link RequestContent}.
+     */
+    public static RequestContent create(byte[] bytes) {
+        Objects.requireNonNull(bytes, "'bytes' cannot be null.");
+        return create(bytes, 0, bytes.length);
+    }
+
+    /**
+     * Creates a {@link RequestContent} comprised of the {@code bytes}.
+     *
+     * @param bytes The bytes that will be the {@link RequestContent} data.
+     * @param offset Offset in the bytes where the data will begin.
+     * @param length Length of the data.
+     * @return A new {@link RequestContent}.
+     */
+    public static RequestContent create(byte[] bytes, int offset, int length) {
+        Objects.requireNonNull(bytes, "'bytes' cannot be null.");
+        return new ArrayContent(bytes, offset, length);
+    }
+
+    /**
+     * Creates a {@link RequestContent} comprised of the {@code content}.
+     *
+     * @param content
+     * @return
+     */
+    public static RequestContent create(String content) {
+        return create(content.getBytes(StandardCharsets.UTF_8));
+    }
+
+    /**
+     *
+     * @param content
+     * @return
+     */
+    public static RequestContent create(BinaryData content) {
+        return create(content.toBytes());
+    }
+
+    /**
+     *
+     * @param serializable
+     * @return
+     */
+    public static RequestContent create(Object serializable) {
+        return create(serializable, null);
+    }
+
+    /**
+     *
+     * @param serializable
+     * @param serializer
+     * @return
+     */
+    public static RequestContent create(Object serializable, ObjectSerializer serializer) {
+        return create(serializer.serializeToBytes(serializable));
+    }
+}

sdk/core/azure-core/src/main/java/com/azure/core/util/RequestOutbound.java

@@ -0,0 +1,7 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.core.util;
+
+public class RequestOutbound {
+}