Updated to more standard stream/async methods.

Author: Oren (electricessence)

Open.Serialization/IDeserializeAsync.cs

@@ -1,14 +1,15 @@
-using System.Threading.Tasks;
+using System.IO;
+using System.Threading.Tasks;
 
 namespace Open.Serialization
 {
 	public interface IDeserializeAsync
 	{
-		ValueTask<T> DeserializeAsync<T>(string value);
+		ValueTask<T> DeserializeAsync<T>(Stream stream);
 	}
 
 	public interface IDeserializeAsync<T>
 	{
-		ValueTask<T> DeserializeAsync(string value);
+		ValueTask<T> DeserializeAsync(Stream stream);
 	}
 }

Open.Serialization/ISerializeAsync.cs

@@ -1,14 +1,15 @@
-using System.Threading.Tasks;
+using System.IO;
+using System.Threading.Tasks;
 
 namespace Open.Serialization
 {
 	public interface ISerializeAsync
 	{
-		ValueTask<string> SerializeAsync<T>(T item);
+		ValueTask SerializeAsync<T>(Stream stream, T item);
 	}
 
 	public interface ISerializeAsync<T>
 	{
-		ValueTask<string> SerializeAsync(T item);
+		ValueTask SerializeAsync(Stream stream, T item);
 	}
 }

Open.Serialization/Open.Serialization.csproj

@@ -15,6 +15,7 @@ Part of the "Open" set of libraries.</Description>
 		<RepositoryUrl>https://github.com/electricessence/Open.Serialization</RepositoryUrl>
 		<RepositoryType>git</RepositoryType>
 		<PackageTags>serialization json</PackageTags>
+		<Version>1.1.0</Version>
 	</PropertyGroup>
 
 	<ItemGroup Condition=" '$(TargetFramework)' == 'netstandard2.0' ">

Open.Serialization/Serializer.cs

@@ -1,20 +1,21 @@
 using System;
+using System.IO;
 using System.Threading.Tasks;
 
 namespace Open.Serialization
 {
 	public class Serializer<T> : SerializerBase<T>
 	{
-		private readonly Func<T, string> _serializer;
 		private readonly Func<string, T> _deserializer;
-		private readonly Func<T, ValueTask<string>> _serializerAsync;
-		private readonly Func<string, ValueTask<T>> _deserializerAsync;
+		private readonly Func<T, string> _serializer;
+		private readonly Func<Stream, ValueTask<T>> _deserializerAsync;
+		private readonly Func<Stream, T, ValueTask> _serializerAsync;
 
 		public Serializer(
 			Func<string, T> deserializer,
 			Func<T, string> serializer = null,
-			Func<string, ValueTask<T>> deserializerAsync = null,
-			Func<T, ValueTask<string>> serializerAsync = null)
+			Func<Stream, ValueTask<T>> deserializerAsync = null,
+			Func<Stream, T, ValueTask> serializerAsync = null)
 		{
 			// It's supported to instantiate a deserializer without a serializer.
 			_deserializer = deserializer ?? throw new ArgumentNullException(nameof(deserializer));
@@ -24,10 +25,10 @@ public Serializer(
 		}
 
 		public override T Deserialize(string value) => _deserializer(value);
-		public override ValueTask<T> DeserializeAsync(string value) => _deserializerAsync(value);
+		public override ValueTask<T> DeserializeAsync(Stream stream) => _deserializerAsync(stream);
 
 		public override string Serialize(T item) => _serializer(item);
-		public override ValueTask<string> SerializeAsync(T item) => _serializerAsync(item);
+		public override ValueTask SerializeAsync(Stream stream, T item) => _serializerAsync(stream, item);
 
 	}
 }

Open.Serialization/SerializerBase.cs

@@ -1,30 +1,50 @@
-using System.Threading.Tasks;
+using System.IO;
+using System.Threading.Tasks;
 
 namespace Open.Serialization
 {
 	public abstract class SerializerBase : ISerializer, IAsyncSerializer
 	{
 		public abstract T Deserialize<T>(string value);
 
-		public virtual ValueTask<T> DeserializeAsync<T>(string value)
-			=> new ValueTask<T>(Deserialize<T>(value));
+		public virtual async ValueTask<T> DeserializeAsync<T>(Stream stream)
+		{
+			string text;
+			using(var reader = new StreamReader(stream))
+				text = await reader.ReadToEndAsync();
+			return Deserialize<T>(text);
+		}
+
 
 		public abstract string Serialize<T>(T item);
 
-		public virtual ValueTask<string> SerializeAsync<T>(T item)
-			=> new ValueTask<string>(Serialize(item));
+		public virtual async ValueTask SerializeAsync<T>(Stream stream, T item)
+		{
+			var text = Serialize(item);
+			using var writer = new StreamWriter(stream);
+			await writer.WriteAsync(text);
+		}
 	}
 
 	public abstract class SerializerBase<T> : ISerializer<T>, IAsyncSerializer<T>
 	{
 		public abstract T Deserialize(string value);
 
-		public virtual ValueTask<T> DeserializeAsync(string value)
-			=> new ValueTask<T>(Deserialize(value));
+		public virtual async ValueTask<T> DeserializeAsync(Stream stream)
+		{
+			string text;
+			using (var reader = new StreamReader(stream))
+				text = await reader.ReadToEndAsync();
+			return Deserialize(text);
+		}
 
 		public abstract string Serialize(T item);
 
-		public virtual ValueTask<string> SerializeAsync(T item)
-			=> new ValueTask<string>(Serialize(item));
+		public virtual async ValueTask SerializeAsync(Stream stream, T item)
+		{
+			var text = Serialize(item);
+			using var writer = new StreamWriter(stream);
+			await writer.WriteAsync(text);
+		}
 	}
 }