com.utilities.extensions 1.3.7 (#36)

- Added `stream.WriteAsync(NativeArray<byte> array, int offset, int count, CancellationToken cancellationToken)`

Author: StephenHodgson

Documentation~/README.md

@@ -52,6 +52,7 @@ openupm add com.utilities.extensions
   - CopyFrom: Copies data from one NativeArray to another while being able to specify the start index and length of data to copy.
   - ToBase64String: Converts a NativeArray to a Base64 string with minimal allocations.
   - FromBase64String: Converts a Base64 string to a NativeArray with minimal allocations.
+  - WriteAsync: Writes to a Stream from a NativeArray asynchronously with minimal allocations.
 
 ### Runtime Utilities
 

Runtime/Extensions/NativeArrayExtensions.cs

@@ -1,7 +1,10 @@
 // Licensed under the MIT License. See LICENSE in the project root for license information.
 
 using System;
+using System.Buffers;
 using System.IO;
+using System.Threading;
+using System.Threading.Tasks;
 using Unity.Collections;
 using Unity.Collections.LowLevel.Unsafe;
 
@@ -59,6 +62,7 @@ public static unsafe NativeArray<byte> ToNativeArray(this MemoryStream stream, i
 
             var bytes = (int)lengthValue;
             var native = new NativeArray<byte>(bytes, allocator);
+
             try
             {
                 fixed (byte* srcPtr = &seg.Array[srcOffset])
@@ -368,5 +372,49 @@ static char GetBase64Char(uint value)
                 };
             }
         }
+
+        public static async Task WriteAsync<T>(this T stream, NativeArray<byte> nativeArray, int? offset = null, int? count = null, CancellationToken cancellationToken = default) where T : Stream
+        {
+            if (stream is null)
+            {
+                throw new ArgumentNullException(nameof(stream));
+            }
+
+            var offsetValue = offset.GetValueOrDefault(0);
+
+            if (offsetValue < 0 || offsetValue > nativeArray.Length)
+            {
+                throw new ArgumentOutOfRangeException(nameof(offset), "Offset must be between 0 and nativeArray.Length.");
+            }
+
+            var countValue = count ?? (nativeArray.Length - offsetValue);
+
+            if (countValue < 0 || offsetValue + countValue > nativeArray.Length)
+            {
+                throw new ArgumentOutOfRangeException(nameof(count), "Invalid count for the provided offset and nativeArray length.");
+            }
+
+            if (countValue == 0) { return; }
+
+            var buffer = ArrayPool<byte>.Shared.Rent(countValue);
+
+            try
+            {
+                unsafe
+                {
+                    fixed (byte* bufferPtr = &buffer[0])
+                    {
+                        var srcPtr = (byte*)nativeArray.GetUnsafeReadOnlyPtr();
+                        UnsafeUtility.MemCpy(bufferPtr, srcPtr + offsetValue, countValue);
+                    }
+                }
+
+                await stream.WriteAsync(buffer, 0, countValue, cancellationToken).ConfigureAwait(false);
+            }
+            finally
+            {
+                ArrayPool<byte>.Shared.Return(buffer);
+            }
+        }
     }
 }

package.json

@@ -3,7 +3,7 @@
   "displayName": "Utilities.Extensions",
   "description": "Common extensions for Unity types (UPM)",
   "keywords": [],
-  "version": "1.3.6",
+  "version": "1.3.7",
   "unity": "2021.3",
   "documentationUrl": "https://github.com/RageAgainstThePixel/com.utilities.extensions#documentation",
   "changelogUrl": "https://github.com/RageAgainstThePixel/com.utilities.extensions/releases",