Merge branch 'release/0.4.1'

powerumc · Mar 26, 2024 · a115267 · a115267
2 parents a06f0f8 + f2a1d79
commit a115267
Showing 1 changed file with 6 additions and 8 deletions.
diff --git a/src/MediatR.Remote/IRemoteSerializer.cs b/src/MediatR.Remote/IRemoteSerializer.cs
@@ -1,4 +1,4 @@
-using System.Text.Json;
+using System.Text;
 
 namespace MediatR.Remote;
 
@@ -14,17 +14,15 @@ public static class RemoteSerializerExtensions
     public static async Task<string> SerializeAsStringAsync<T>(this IRemoteSerializer serializer, T value,
         CancellationToken cancellationToken = default)
     {
-        // var stream = await serializer.SerializeAsync(value, cancellationToken);
-        // using var reader = new StreamReader(stream);
-        // return await reader.ReadToEndAsync();
-        return JsonSerializer.Serialize(value);
+        var stream = await serializer.SerializeAsync(value, cancellationToken);
+        using var reader = new StreamReader(stream);
+        return await reader.ReadToEndAsync();
     }
 
     public static async Task<T?> DeserializeFromStringAsync<T>(this IRemoteSerializer serializer, string value,
         CancellationToken cancellationToken = default)
     {
-        // await using var stream = new MemoryStream(Encoding.UTF8.GetBytes(value));
-        // return await serializer.DeserializeAsync<T>(stream, cancellationToken);
-        return JsonSerializer.Deserialize<T>(value);
+        await using var stream = new MemoryStream(Encoding.UTF8.GetBytes(value));
+        return await serializer.DeserializeAsync<T>(stream, cancellationToken);
     }
 }