Simplified API and tested.

Author: Oren (electricessence)

Open.Serialization.Json.Newtonsoft/JsonSerializerFactory.cs

@@ -17,13 +17,11 @@ public JsonSerializerFactory(JsonSerializerSettings defaultOptions = null)
 		JsonSerializerInternal _default;
 		JsonSerializerInternal Default => LazyInitializer.EnsureInitialized(ref _default, () => new JsonSerializerInternal(_settings));
 
-		protected override SerializerBase GetDeserializerInternal(bool caseSensitive)
-			=> caseSensitive
-			? throw new NotSupportedException("Newtonsoft does not support case-sensitive deserialization.")
-			: Default;
-
-		protected override SerializerBase GetSerializerInternal(IJsonSerializationOptions options)
+		public override IJsonSerializer GetSerializer(IJsonSerializationOptions options = null, bool caseSensitive = false)
 		{
+			if (caseSensitive)
+				throw new NotSupportedException("Newtonsoft does not support case-sensitive deserialization.");
+
 			if (options == null) return Default;
 
 			if (options.CamelCaseKeys && !options.CamelCaseProperties)

Open.Serialization.Json.Newtonsoft/Open.Serialization.Json.Newtonsoft.csproj

@@ -22,7 +22,7 @@ Part of the "Open" set of libraries.
 
 	<ItemGroup>
 		<PackageReference Include="Newtonsoft.Json" Version="11.0.1" />
-		<PackageReference Include="Open.Serialization.Json" Version="1.0.1" />
+		<PackageReference Include="Open.Serialization.Json" Version="1.2.0" />
 	</ItemGroup>
 
 </Project>

Open.Serialization.Json.System/JsonSerializerInternal.cs

@@ -1,10 +1,11 @@
 using System.IO;
 using System.Text.Json;
+using System.Threading;
 using System.Threading.Tasks;
 
 namespace Open.Serialization.Json.System
 {
-	internal class JsonSerializerInternal : JsonSerializerBase
+	internal class JsonSerializerInternal : JsonSerializerBase, IJsonSerializer
 	{
 		readonly JsonSerializerOptions _options;
 		internal JsonSerializerInternal(JsonSerializerOptions options)
@@ -15,18 +16,41 @@ internal JsonSerializerInternal(JsonSerializerOptions options)
 		public override T Deserialize<T>(string value)
 			=> JsonSerializer.Deserialize<T>(value, _options);
 
+		public new Task SerializeAsync<T>(Stream stream, T item, CancellationToken cancellationToken = default)
+			=> JsonSerializer.SerializeAsync(stream, item, _options, cancellationToken);
+
+		ValueTask ISerializeAsync.SerializeAsync<T>(Stream stream, T item, CancellationToken cancellationToken)
+			=> new ValueTask(SerializeAsync(stream, item, cancellationToken));
+
 		public override string Serialize<T>(T item)
 			=> JsonSerializer.Serialize(item, _options);
 
-		public override ValueTask<T> DeserializeAsync<T>(Stream stream)
+		public override ValueTask<T> DeserializeAsync<T>(Stream stream, CancellationToken cancellationToken = default)
 			=> JsonSerializer.DeserializeAsync<T>(stream, _options);
 	}
 
-	internal class JsonSerializerInternal<T> : Serializer<T>, IJsonSerializer<T>
+
+	internal class JsonSerializerInternal<T> : JsonSerializerBase<T>, IJsonSerializer<T>
 	{
+		readonly JsonSerializerOptions _options;
 		internal JsonSerializerInternal(JsonSerializerOptions options)
-			:base(options.GetDeserialize<T>(), options.GetSerialize<T>())
 		{
+			_options = options;
 		}
+
+		public override T Deserialize(string value)
+			=> JsonSerializer.Deserialize<T>(value, _options);
+
+		public new Task SerializeAsync(Stream stream, T item, CancellationToken cancellationToken = default)
+			=> JsonSerializer.SerializeAsync(stream, item, _options, cancellationToken);
+
+		ValueTask ISerializeAsync<T>.SerializeAsync(Stream stream, T item, CancellationToken cancellationToken)
+			=> new ValueTask(SerializeAsync(stream, item, cancellationToken));
+
+		public override string Serialize(T item)
+			=> JsonSerializer.Serialize(item, _options);
+
+		public override ValueTask<T> DeserializeAsync(Stream stream, CancellationToken cancellationToken = default)
+			=> JsonSerializer.DeserializeAsync<T>(stream, _options);
 	}
 }

Open.Serialization.Json.System/Open.Serialization.Json.System.csproj

@@ -21,7 +21,7 @@ Part of the "Open" set of libraries.
 	</PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Open.Serialization.Json" Version="1.1.2" />
+    <PackageReference Include="Open.Serialization.Json" Version="1.2.0" />
     <PackageReference Include="System.Text.Json" Version="4.6.0" />
   </ItemGroup>
 

Open.Serialization.Json/Open.Serialization.Json.csproj

@@ -17,11 +17,11 @@ Part of the "Open" set of libraries.
 		<RepositoryUrl>https://github.com/electricessence/Open.Serialization</RepositoryUrl>
 		<RepositoryType>git</RepositoryType>
 		<PackageTags>serialization json</PackageTags>
-		<Version>1.1.2</Version>
+		<Version>1.2.0</Version>
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Open.Serialization" Version="1.1.2" />
+    <PackageReference Include="Open.Serialization" Version="1.2.0" />
   </ItemGroup>
 
 </Project>

Open.Serialization.Tests/ParityTests.cs

@@ -33,8 +33,8 @@ static void CompareFactories(IJsonSerializerFactory expectedFactory, IJsonSerial
 			Assert.Equal(expectedSerializer.Serialize(SampleModel.DecimalLookup), actualSerializer.Serialize(SampleModel.DecimalLookup));
 			Assert.Equal(expectedSerializer.Serialize(SampleModel.DoubleLookup), actualSerializer.Serialize(SampleModel.DoubleLookup));
 
-			expectedFactory.GetDeserializer().Deserialize<SampleModel>(actualSerializer.Serialize(SampleModel.Instance));
-			actualFactory.GetDeserializer().Deserialize<SampleModel>(expectedSerializer.Serialize(SampleModel.Instance));
+			expectedFactory.GetSerializer().Deserialize<SampleModel>(actualSerializer.Serialize(SampleModel.Instance));
+			actualFactory.GetSerializer().Deserialize<SampleModel>(expectedSerializer.Serialize(SampleModel.Instance));
 		}
 	}
 }