Fix binary incompatibility with RecyclableMemoryStream v3.0.0 (#247)

AllocZero · May 25, 2024 · a871096 · a871096
1 parent 6e40d97
commit a871096
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/EfficientDynamoDb/Internal/ErrorHandler.cs b/src/EfficientDynamoDb/Internal/ErrorHandler.cs
@@ -11,6 +11,7 @@
 using EfficientDynamoDb.Internal.Operations.Shared;
 using EfficientDynamoDb.Internal.Reader;
 using EfficientDynamoDb.Operations.Shared;
+using Microsoft.IO;
 
 namespace EfficientDynamoDb.Internal
 {
@@ -29,7 +30,7 @@ public static async Task ProcessErrorAsync(DynamoDbContextMetadata metadata, Htt
                 if (response.StatusCode == HttpStatusCode.ServiceUnavailable)
                     throw new ServiceUnavailableException("DynamoDB is currently unavailable. (This should be a temporary state.)");
 
-                var recyclableStream = DynamoDbHttpContent.MemoryStreamManager.GetStream();
+                var recyclableStream = new RecyclableMemoryStream(DynamoDbHttpContent.MemoryStreamManager);
                 try
                 {
                     await responseStream.CopyToAsync(recyclableStream, cancellationToken).ConfigureAwait(false);

diff --git a/src/EfficientDynamoDb/Internal/Operations/Shared/DynamoDbHttpContent.cs b/src/EfficientDynamoDb/Internal/Operations/Shared/DynamoDbHttpContent.cs
@@ -40,7 +40,7 @@ private async Task<Stream> CreatePooledContentReadStreamAsync()
             if (_pooledContentStream != null)
                 return _pooledContentStream;
 
-            _pooledContentStream = MemoryStreamManager.GetStream();
+            _pooledContentStream = new RecyclableMemoryStream(MemoryStreamManager);
 
             await SerializeToStreamAsync(_pooledContentStream, null).ConfigureAwait(false);